Bedrock AgentCore Runtime の WebRTC サポートで音声エージェントを構築する

agent/
  bot.py              - FastAPI サーバー、WebRTC シグナリング
  kvs.py              - KVS シグナリングチャネルと TURN 資格情報
  audio.py            - 音声リサンプリングと WebRTC 出力トラック
  nova_sonic.py       - Nova Sonic 双方向ストリーミングセッション
  requirements.txt
  Dockerfile
server/
  index.html          - ブラウザクライアント
  server.py           - 静的ファイルサーバー

git clone https://github.com/awslabs/amazon-bedrock-agentcore-samples.git
cd amazon-bedrock-agentcore-samples/01-tutorials/01-AgentCore-runtime/06-bi-directional-streaming-webrtc
 
cd agent
python3.12 -m venv venv && source venv/bin/activate
pip install -r requirements.txt
export AWS_REGION=us-west-2
export KVS_CHANNEL_NAME=voice-agent-minimal
python bot.py --host 0.0.0.0 --port 8080

cd server
source ../agent/venv/bin/activate
python server.py  # http://localhost:7860

Signaling channel: arn:aws:kinesisvideo:us-west-2:123456789012:channel/voice-agent-minimal/...
Uvicorn running on http://0.0.0.0:8080

1. ice_config    → KVS TURN/STUN サーバーの資格情報を取得
2. offer         → ブラウザの SDP Offer を送信、エージェントが Answer を返す
3. ice_candidate → ICE 候補を交換（Trickle ICE）
4. 接続確立      → 音声の双方向ストリーミング開始

# VPC 作成
VPC_ID=$(aws ec2 create-vpc --cidr-block 10.0.0.0/16 --region us-west-2 \
  --tag-specifications 'ResourceType=vpc,Tags=[{Key=Name,Value=webrtc-bot-example}]' \
  --query 'Vpc.VpcId' --output text)
aws ec2 modify-vpc-attribute --vpc-id $VPC_ID --enable-dns-hostnames '{"Value": true}' --region us-west-2
 
# Internet Gateway
IGW=$(aws ec2 create-internet-gateway --region us-west-2 --query 'InternetGateway.InternetGatewayId' --output text)
aws ec2 attach-internet-gateway --internet-gateway-id $IGW --vpc-id $VPC_ID --region us-west-2
 
# パブリックサブネット + プライベートサブネット
PUBLIC_SUBNET=$(aws ec2 create-subnet --vpc-id $VPC_ID --cidr-block 10.0.1.0/24 \
  --availability-zone us-west-2a --region us-west-2 --query 'Subnet.SubnetId' --output text)
PRIVATE_SUBNET=$(aws ec2 create-subnet --vpc-id $VPC_ID --cidr-block 10.0.2.0/24 \
  --availability-zone us-west-2a --region us-west-2 --query 'Subnet.SubnetId' --output text)
 
# NAT Gateway（作成完了まで数分かかる）
EIP_ALLOC=$(aws ec2 allocate-address --domain vpc --region us-west-2 --query 'AllocationId' --output text)
NAT_GW=$(aws ec2 create-nat-gateway --subnet-id $PUBLIC_SUBNET --allocation-id $EIP_ALLOC \
  --region us-west-2 --query 'NatGateway.NatGatewayId' --output text)
aws ec2 wait nat-gateway-available --nat-gateway-ids $NAT_GW --region us-west-2

cd agent
pip install bedrock-agentcore-starter-toolkit
 
agentcore configure \
  -e bot.py \
  --deployment-type container \
  --disable-memory \
  --vpc \
  --subnets $PRIVATE_SUBNET \
  --security-groups $SG_ID \
  --region us-west-2 \
  --non-interactive
 
# デプロイ（CodeBuild で ARM64 コンテナをビルド、数分かかる）
agentcore deploy --env KVS_CHANNEL_NAME=voice-agent-minimal --env AWS_REGION=us-west-2

Agent ARN: arn:aws:bedrock-agentcore:us-west-2:123456789012:runtime/bot-XXXXXXXXXX
Execution role: AmazonBedrockAgentCoreSDKRuntime-us-west-2-XXXXXXXXXX

ROLE_NAME="AmazonBedrockAgentCoreSDKRuntime-us-west-2-XXXXXXXXXX"  # デプロイ出力から取得
 
cd ..  # プロジェクトルートに移動（kvs-iam-policy.json がある場所）
 
# kvs-iam-policy.json の ACCOUNT_ID を自分のアカウント ID に置換
sed -i "s/ACCOUNT_ID/$(aws sts get-caller-identity --query Account --output text)/" kvs-iam-policy.json

# bedrock-iam-policy.json を修正（アカウント ID 部分を空にする）
cat > bedrock-iam-policy.json << 'EOF'
{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": "bedrock:InvokeModelWithBidirectionalStream",
            "Resource": "arn:aws:bedrock:us-west-2::foundation-model/amazon.nova-2-sonic-v1:0"
        }
    ]
}
EOF
 
# ポリシーをアタッチ
aws iam put-role-policy --role-name $ROLE_NAME --policy-name kvs-access \
  --policy-document file://kvs-iam-policy.json
aws iam put-role-policy --role-name $ROLE_NAME --policy-name bedrock-nova-sonic \
  --policy-document file://bedrock-iam-policy.json

cd agent
agentcore status
# Endpoint: DEFAULT (READY) と表示されるまで待つ

cd ../server
source ../agent/venv/bin/activate
python server.py  # http://localhost:7860

Receive error: InternalErrorCode=531::Timed out waiting for audio bytes
or interactive content. Please ensure gaps between audio bytes and
interactive content are less than 295 seconds.

User: nice to meet you, i am gina hart.
Nova Sonic: Nice to meet you, Gina Hart! I'm here to chat and assist
with any questions or topics you'd like to discuss.

Audio send error:
concurrent.futures._base.InvalidStateError: CANCELLED
Unclosed client session

# AgentCore デプロイの削除
cd agent && agentcore destroy
 
# KVS シグナリングチャネルの削除
aws kinesisvideo delete-signaling-channel \
  --channel-arn arn:aws:kinesisvideo:us-west-2:ACCOUNT_ID:channel/voice-agent-minimal/... \
  --region us-west-2