Amazon Bedrock AgentCore harness と AWS Step Functions を組み合わせて安全に AI エージェントを構築してみよう !

[
  {
    "Content": [
      {
        "Text": "今日の日付を確認して、AWS Knowledge MCP を利用し、今週の AWS What's New をサマリーしてください。"
      }
    ],
    "Role": "user"
  }
]

"SendApprovalEmail": {
  "Type": "Task",
  "Resource": "arn:aws:states:::aws-sdk:sesv2:sendEmail.waitForTaskToken",
  "Arguments": {
    "FromEmailAddress": "your-email-address",
    "Destination": {
      "ToAddresses": ["your-email-address"]
    },
    "Content": {
      "Simple": {
        "Subject": { "Data": "{% '【承認依頼】AgentCore harness output for: ' & $userMessage %}" },
        "Body": {
          "Text": {
            "Data": "{% $agentText & '\n\n---\n✅ 承認する: https://your-approval-api/approve?token=' & $states.context.Task.Token & '\n❌ 却下する: https://your-approval-api/reject?token=' & $states.context.Task.Token %}"
//省略
}

あなたは AWS の最新アップデート(AWS What's New)を監視し、自社が運用するサービスへの影響を分析する調査アシスタントです。

【自社が運用するサービスの前提】
- Amazon ECS 上で稼働するコンテナ化された Web API 群
- Amazon Aurora PostgreSQL をデータストアとして使用
- Amazon S3 + CloudFront による静的配信
- Amazon Bedrock を用いた生成 AI 機能

【あなたのタスク】
ユーザーから渡された AWS のアップデート情報について、必要に応じて aws_knowledge ツール(search_documentation / read_documentation)で一次情報を確認し、以下を判断・作成してください。
1. そのアップデートが上記の自社運用サービスに関連するかどうかを判断する。
2. 関連する場合は、詳細調査結果と影響度分析(何が変わるか、どのサービスに、どの程度の影響か、推奨アクション)をまとめる。

【出力形式】
必ず次の JSON オブジェクトだけを出力してください。前後に説明文やマークダウンのコードブロックを付けてはいけません。

{
  "relevant": true または false,
  "subject": "メール件名(関連ありの場合のみ。日本語)",
  "impact_level": "high | medium | low(関連ありの場合のみ)",
  "affected_services": ["影響を受ける自社サービス名の配列"],
  "report": "関連チーム向けの詳細調査結果と影響度分析レポート本文(日本語のプレーンテキスト。関連ありの場合のみ)",
  "reason": "関連なしと判断した場合の理由(関連なしの場合のみ)"
}

事実と推論を区別し、確認できた一次情報に基づいて記述してください。断定できない点は推測であることを明示してください。

{
  "mcp": {
    "lambda": {
      "lambdaArn": "arn:aws:lambda:region:accountid:function:waat-email-tool",
      "toolSchema": {
        "inlinePayload": [
          {
            "name": "send_email",
            "description": "Send an email. Use this tool whenever the user asks to send an email. Returns a confirmation message in Japanese.",
            "inputSchema": {
              "type": "object",
              "properties": {
                "to": { "type": "string", "description": "recipient email address" },
                "subject": { "type": "string", "description": "email subject" },
                "body": { "type": "string", "description": "email body" }
              },
              "required": ["to"]
            },
            "outputSchema": {
              "type": "object",
              "properties": { "result": { "type": "string", "description": "confirmation message" } }
            }
          }
        ]
      }
    }
  }
}

import json
import os
import boto3

sfn = boto3.client("stepfunctions")
STATE_MACHINE_ARN = os.environ["STATE_MACHINE_ARN"]
DELIMITER = "___"

def lambda_handler(event, context):
    # Resolve the invoked tool name (format: "<target>___<tool>")
    tool_name = None
    try:
        original = context.client_context.custom["bedrockAgentCoreToolName"]
        tool_name = original.split(DELIMITER, 1)[-1]
    except Exception:
        tool_name = "send_email"

    # Start a synchronous execution of State Machine A.
    resp = sfn.start_sync_execution(
        stateMachineArn=STATE_MACHINE_ARN,
        input=json.dumps(event or {}),
    )

    status = resp.get("status")
    if status != "SUCCEEDED":
        return {
            "statusCode": 500,
            "error": f"State Machine A did not succeed: {status}",
            "cause": resp.get("cause"),
        }

    output = json.loads(resp.get("output") or "{}")
    # output == {"message": "メールを送信しました"}
    return {
        "tool": tool_name,
        "result": output.get("message", output),
        "stateMachineExecutionArn": resp.get("executionArn"),
    }

{
  "Comment": "...",
  "StartAt": "Investigate",
  "States": {
    "Investigate": {
      "Type": "Task",
      "Resource": "arn:aws:states:::bedrockagentcore:invokeHarness",
      "Parameters": {
        "HarnessArn": "arn:aws:bedrock-agentcore:region:accountId:harness/harnessId",
        "RuntimeSessionId.$": "States.Format('{}{}', $$.Execution.Name, $$.Execution.Name)",
        "Messages": [
          {
            "Role": "user",
            "Content": [
              { "Text.$": "States.Format('AWS の最新アップデート情報で次のものを観測しました: {}。このアップデートについて調査し、自社サービスへの影響度分析レポートを作成してください。', $.whatsNew)" }
            ]
          }
        ]
      },
      "Next": "SendReport"
    },
    "SendReport": {
      "Type": "Task",
      "Resource": "arn:aws:states:::aws-sdk:sesv2:sendEmail",
      "Parameters": {
        "FromEmailAddress": "your-email-address",
        "Destination": {
          "ToAddresses": ["your-email-address"]
        },
        "Content": {
          "Simple": {
            "Subject": {
              "Data": "AWS アップデート影響分析レポート",
              "Charset": "UTF-8"
            },
            "Body": {
              "Text": {
                "Data.$": "$.Output.Message.Content[0].Text",
                "Charset": "UTF-8"
              }
            }
          }
        }
      },
      "End": true
    }
  }
}