┌─────────────────┐    ┌──────────────────┐    ┌─────────────────┐
│   CDK Stack     │    │  AgentCore       │    │  Bedrock        │
│                 │    │  Runtime         │    │  Memory         │
│ • ECR Repo      │───▶│                  │───▶│                 │
│ • IAM Roles     │    │ • Agent Container│    │ • Session Store │
│ • Permissions   │    │ • Strands Agent  │    │ • Context       │
└─────────────────┘    └──────────────────┘    └─────────────────┘

const agentRepository = new ecr.Repository(this, 'AgentRepository', {
  repositoryName: 'bedrock-agentcore-sample',
  removalPolicy: cdk.RemovalPolicy.DESTROY,
});

const executionRole = new iam.Role(this, 'AgentCoreExecutionRole', {
  assumedBy: new iam.ServicePrincipal('bedrock-agentcore.amazonaws.com'),
  inlinePolicies: {
    AgentCorePolicy: new iam.PolicyDocument({
      statements: [
        new iam.PolicyStatement({
          actions: [
            'bedrock:InvokeModel',
            'bedrock-agent:CreateEvent',
            'bedrock-agent:GetMemory',
            'logs:CreateLogGroup',
            // ... các quyền bổ sung
          ],
          resources: ['*'],
        }),
      ],
    }),
  },
});

from bedrock_agentcore import BedrockAgentCoreApp
from strands import Agent
import boto3

app = BedrockAgentCoreApp()
agent = Agent()

@app.entrypoint
def invoke(payload):
    user_message = payload.get("prompt", "Xin chào!")
    session_id = "custom-session-12345678901234567890123"

    # Tích hợp bộ nhớ cho tính liên tục trong cuộc trò chuyện
    memory_client = boto3.client('bedrock-agent', region_name='eu-central-1')

    # Lưu trữ tin nhắn người dùng và lấy ngữ cảnh
    # Nhận phản hồi của agent với ngữ cảnh được cải thiện
    # Lưu trữ phản hồi của agent cho ngữ cảnh tương lai

    return {"result": result.message, "sessionId": session_id}

npm install
npx cdk bootstrap --region eu-central-1
npx cdk deploy

cd agent
pip install bedrock-agentcore strands-agents bedrock-agentcore-starter-toolkit
agentcore configure -e my_agent.py --region eu-central-1
agentcore launch

default_agent: my_agent
agents:
  my_agent:
    name: my_agent
    entrypoint: my_agent.py
    platform: linux/arm64
    aws:
      region: eu-central-1
      network_configuration:
        network_mode: PUBLIC
      observability:
        enabled: true

# Lưu trữ các sự kiện cuộc trò chuyện
memory_client.create_event(
    memoryId=MEMORY_ID,
    actorId=ACTOR_ID,
    sessionId=session_id,
    eventTimestamp=datetime.utcnow(),
    payload={"message": user_message, "role": "user"}
)

# Lấy ngữ cảnh cuộc trò chuyện
memory_response = memory_client.get_memory(
    memoryId=MEMORY_ID,
    actorId=ACTOR_ID,
    sessionId=session_id
)

cd agent
agentcore invoke '{"prompt": "Bạn có thể giúp tôi điều gì?"}'

import json
import boto3
import uuid
from datetime import datetime

def handler(event, context):
    try:
        # Phân tích yêu cầu
        body = json.loads(event['body'])
        prompt = body.get('prompt', '')

        # Tạo client AgentCore (cùng khu vực)
        client = boto3.client('bedrock-agentcore', region_name='eu-central-1')

        # Tạo ID phiên nhất quán (giống như agent sử dụng)
        session_id = 'custom-session-12345678901234567890123'

        # Gọi AgentCore Runtime
        payload = json.dumps({"prompt": prompt})

        response = client.invoke_agent_runtime(
            agentRuntimeArn='arn:aws:bedrock-agentcore:eu-central-1:{accountId}:runtime/my_agent-{customString}',
            runtimeSessionId=session_id,
            payload=payload,
            qualifier="DEFAULT"
        )

        # Phân tích phản hồi
        response_body = b''.join(response['response']).decode('utf-8')
        response_data = json.loads(response_body)

        return {
            'statusCode': 200,
            'headers': {
                'Content-Type': 'application/json',
                'Access-Control-Allow-Origin': '*',
                'Access-Control-Allow-Methods': 'POST, OPTIONS',
                'Access-Control-Allow-Headers': 'Content-Type'
            },
            'body': json.dumps({
                'response': response_data['result']['content'][0]['text'],
                'sessionId': session_id
            })
        }

    except Exception as e:
        print(f"Error: {str(e)}")
        return {
            'statusCode': 500,
            'headers': {
                'Content-Type': 'application/json',
                'Access-Control-Allow-Origin': '*'
            },
            'body': json.dumps({'error': str(e)})
        }

npx cdk destroy
# Xóa AgentCore Runtime từ console hoặc CLI