AgentCore Runtime Instances がリリースされました！

EventBridge managed rule creation failed. User: arn:aws:sts::123456789012:assumed-role/agentcore-cp-operator-role/AgentCore is not authorized to perform: events:PutRule on resource: arn:aws:events:us-east-1:123456789012:rule/agentcore-lifecycle-events-123456789012

@app.entrypoint
def handler(event, context):
    haiku = compose_haiku(event.get("theme", "クラウド"))  # Bedrockで俳句を生成

    # 共有ボリュームに書き込む（同じセッションのreviewerが読む）
    session_dir = SHARED_DIR / context.session_id  # SHARED_DIR = /mnt/shared
    session_dir.mkdir(parents=True, exist_ok=True)
    (session_dir / "haiku.txt").write_text(haiku, encoding="utf-8")

    return {
        "agent": "writer",
        "haiku": haiku,
        "hostname": socket.gethostname(),   # 同一インスタンスの確認用
        "arch": platform.machine(),          # CPUアーキテクチャの確認用
    }

uv init agentcore-instances-demo --python 3.13
cd agentcore-instances-demo
uv add bedrock-agentcore boto3

uv pip install \
  --python-platform aarch64-manylinux2014 \
  --python-version 3.13 \
  --target build/deps \
  --only-binary=:all: \
  bedrock-agentcore boto3

cd build/deps && zip -qr ../writer.zip . && cd ../..
cd agents/writer && zip -q ../../build/writer.zip main.py && cd ../..

aws s3 cp build/writer.zip s3://bedrock-agentcore-code-123456789012-us-east-1/writer/deployment_package.zip

response = client.create_capacity_provider(
    name="haiku_demo_cp",
    permissionsConfiguration={"capacityProviderOperatorRoleArn": OPERATOR_ROLE_ARN},
    computeConfiguration={
        "ec2Configuration": {
            "launchTemplateSource": {
                "launchParameters": {
                    "operatingSystem": "LINUX_ARM64",
                    "instanceRequirements": {"allowedInstanceTypes": ["m7g.large"]},
                    "instanceProfileArn": INSTANCE_PROFILE_ARN,
                }
            },
            "vpcConfiguration": {"subnets": [SUBNET_ID], "securityGroups": [SG_ID]},
            "volumes": [{"ebsConfiguration": {"name": "shared", "sizeGiB": 10, "volumeType": "gp3"}}],
        }
    },
)

for name in ["writer", "reviewer"]:
    client.create_agent_runtime(
        agentRuntimeName=f"haiku_{name}",
        roleArn=EXEC_ROLE_ARN,
        agentRuntimeArtifact={
            "codeConfiguration": {
                "code": {"s3": {"bucket": BUCKET, "prefix": f"{name}/deployment_package.zip"}},
                "runtime": "PYTHON_3_13",
                "entryPoint": ["main.py"],
            }
        },
        capacityProviderConfiguration={"capacityProviderArn": CP_ARN},
        filesystemConfigurations=[
            {"capacityProviderVolume": {"volumeName": "shared", "mountPath": "/mnt/shared"}}
        ],
    )

import json

import boto3

client = boto3.client("bedrock-agentcore", region_name="us-east-1")

# 33文字以上のセッションID。同じIDを使い回すことで同一EC2インスタンスで実行
session_id = "haiku-collab-session-2026-08-07-demo-001"

response = client.invoke_agent_runtime(
    agentRuntimeArn=WRITER_ARN,
    runtimeSessionId=session_id,
    payload=json.dumps({"theme": "夏のEC2インスタンス"}).encode(),
    qualifier="DEFAULT",
)
print(json.loads(response["response"].read()))

response = client.invoke_agent_runtime(
    agentRuntimeArn=REVIEWER_ARN,
    runtimeSessionId=session_id,
    payload=json.dumps({}).encode(),
    qualifier="DEFAULT",
)
print(json.loads(response["response"].read()))

uv run python scripts/03_invoke_agents.py

{
  "agent": "writer",
  "haiku": "クラウド冷え\nワーカー立ちて\n夏涼し",
  "hostname": "ip-172-31-3-249.ec2.internal",
  "arch": "aarch64",
  "wrote_to": "/mnt/shared/haiku-collab-session-2026-08-07-demo-001/haiku.txt"
}

{
  "agent": "reviewer",
  "haiku_read_from_shared_volume": "クラウド冷え\nワーカー立ちて\n夏涼し",
  "review": "この句は季語「夏涼し」に現代的な「クラウド」「ワーカー」を組み合わせた意欲的な試みですが、造語的な措辞が唐突で、俳句の伝統的な余韻に欠けます。（以下略）",
  "hostname": "ip-172-31-3-249.ec2.internal",
  "arch": "aarch64"
}

aws ec2 modify-managed-resource-visibility --default-visibility visible

|  Id       |  i-0cb7e904f61796067              |
|  Ip       |  172.31.3.249                     |
|  Operator |  bedrock-agentcore.amazonaws.com  |
|  State    |  running                          |
|  Type     |  m7g.large                        |

aws bedrock-agentcore stop-runtime-session \
  --agent-runtime-arn arn:aws:bedrock-agentcore:us-east-1:123456789012:runtime/haiku_reviewer-XAGNbiCcJJ \
  --runtime-session-id haiku-collab-session-2026-08-07-demo-001

response = client.invoke_agent_runtime(
    agentRuntimeArn=REVIEWER_ARN,
    runtimeSessionId="haiku-collab-session-2026-08-07-demo-001",
    payload=json.dumps({}).encode(),
    qualifier="DEFAULT",
)

haiku: クラウド冷え / ワーカー立ちて / 夏涼し
hostname: ip-172-31-15-99.ec2.internal

session_id = "a2a-demo-session-2026-08-07-test-00001"
for arn in [PINGSERVER_ARN, PINGCLIENT_ARN]:
    response = client.invoke_agent_runtime(
        agentRuntimeArn=arn,
        runtimeSessionId=session_id,
        payload=json.dumps({}).encode(),
        qualifier="DEFAULT",
    )
    print(json.loads(response["response"].read()))

{
  "agent": "pingclient",
  "hostname": "ip-172-31-5-39.ec2.internal",
  "listening_ports_visible": [8080],
  "via_localhost": {"ok": false, "error": "URLError: <urlopen error [Errno 111] Connection refused>"},
  "via_private_ip": {"ok": false, "error": "URLError: <urlopen error [Errno 111] Connection refused>"}
}

client.create_agent_runtime(
    agentRuntimeName="a2a_haiku_poet",
    protocolConfiguration={"serverProtocol": "A2A"},
    capacityProviderConfiguration={"capacityProviderArn": CP_ARN},
    ...
)

payload = {
    "jsonrpc": "2.0",
    "id": "req-001",
    "method": "message/send",
    "params": {
        "message": {
            "role": "user",
            "parts": [{"kind": "text", "text": "秋のデータセンター"}],
            "messageId": "msg-001",
        }
    },
}
response = client.invoke_agent_runtime(
    agentRuntimeArn=POET_ARN,
    runtimeSessionId="a2a-jsonrpc-session-2026-08-07-poc-0002",
    payload=json.dumps(payload).encode(),
    qualifier="DEFAULT",
)

{
  "jsonrpc": "2.0",
  "id": "req-001",
  "result": {
    "artifacts": [
      {
        "name": "haiku",
        "parts": [{"kind": "text", "text": "秋風吹く　サーバー室より　熱気立つ"}]
      }
    ]
  }
}

@app.entrypoint
def handler(event, context):
    payload = {
        "jsonrpc": "2.0",
        "id": str(uuid.uuid4()),
        "method": "message/send",
        "params": {"message": {"role": "user",
                               "parts": [{"kind": "text", "text": event.get("theme")}],
                               "messageId": str(uuid.uuid4())}},
    }
    response = agentcore.invoke_agent_runtime(
        agentRuntimeArn=POET_ARN,
        runtimeSessionId=context.session_id,  # 自分と同じセッションID → 同一インスタンスに同居
        payload=json.dumps(payload).encode(),
        qualifier="DEFAULT",
    )
    ...

{
  "agent": "a2aclient",
  "client_hostname": "ip-172-31-3-93.ec2.internal",
  "poet_hostname": "ip-172-31-3-93.ec2.internal",
  "haiku": "夜更けまで　データ流れて　朝を待つ"
}

# 1. セッション削除（EC2・ENI・EBSをまとめて解放）
data.delete_capacity_provider_session(capacityProviderId=CP_ID, sessionId=SESSION_ID)

# 2. Runtime削除
for rid in RUNTIME_IDS:
    control.delete_agent_runtime(agentRuntimeId=rid)

# 3. Runtimeの削除完了を待ってからCapacity Provider削除
control.delete_capacity_provider(capacityProviderId=CP_ID)

 response = client.create_capacity_provider(
-    name="haiku_demo_cp",
+    name="x86_demo_cp",
     permissionsConfiguration={"capacityProviderOperatorRoleArn": OPERATOR_ROLE_ARN},
     computeConfiguration={
         "ec2Configuration": {
             "launchTemplateSource": {
                 "launchParameters": {
-                    "operatingSystem": "LINUX_ARM64",
-                    "instanceRequirements": {"allowedInstanceTypes": ["m7g.large"]},
+                    "operatingSystem": "LINUX_X86_64",
+                    "instanceRequirements": {"allowedInstanceTypes": ["m7i.large"]},
                     "instanceProfileArn": INSTANCE_PROFILE_ARN,
                 }
             },
             "vpcConfiguration": {"subnets": [SUBNET_ID], "securityGroups": [SG_ID]},
             "volumes": [{"ebsConfiguration": {"name": "shared", "sizeGiB": 10, "volumeType": "gp3"}}],
         }
     },
 )

uv pip install \
  --python-platform x86_64-manylinux2014 \
  --python-version 3.13 \
  --target build/deps-x86 \
  --only-binary=:all: \
  bedrock-agentcore boto3

{
  "agent": "writer",
  "haiku": "電算機\nシリコン奏でし\nビット舞う",
  "hostname": "ip-172-31-15-215.ec2.internal",
  "arch": "x86_64"
}

11:46:15  CreateAutoScalingGroup   AgentCore   ← Capacity Provider作成時（裏側はASG管理）
11:47:13  RunInstances             AgentCore   ← セッション初回呼び出しでEC2起動
11:47:30  CreateVolume             AgentCore   ← 共有ボリュームもセッションごとに新規作成
11:47:36  AttachVolume             AgentCore
（検証2でRuntime停止 → インスタンスはstoppedに）
12:22:52  RunInstances             AgentCore   ← 同じセッションIDで再呼び出し、新インスタンス起動
12:24:06  TerminateInstances       AutoScaling ← 旧インスタンスは終了
12:24:10  AttachVolume             AgentCore   ← EBSを新インスタンスに再アタッチ
12:25:12  TerminateInstances       AgentCore   ← セッション削除
12:25:18  DeleteVolume             AgentCore   ← このタイミングで初めてEBSが消える