[アップデート] Amazon Bedrock Flows が非同期実行をパブリックプレビューでサポートしました

import boto3
import uuid
import time

# Bedrock Agentランタイムクライアントの作成
session = boto3.Session(profile_name='hoge')
client = session.client('bedrock-agent-runtime', region_name='ap-northeast-1')

# randomなUUIDを生成
uuid_value = str(uuid.uuid4())

# フロー実行の開始
response = client.start_flow_execution(
    flowIdentifier='DX8YKMNT10',
    flowAliasIdentifier='ZYCEKBO7NL',
    inputs=[{
        'nodeName': 'FlowInputNode',
        'nodeOutputName': 'document',
        'content': {
            'document': 'こんにちは、これは非同期実行のテストです。'
        }
    }],
    flowExecutionName=f'AsyncTest-{uuid_value[:8]}',
)

print(response)

flow-sample % poetry run python app.py
{'ResponseMetadata': {'RequestId': 'a78038ec-77d7-40fa-bb19-3a966175d633', 'HTTPStatusCode': 200, 'HTTPHeaders': {'date': 'Fri, 20 Jun 2025 10:44:02 GMT', 'content-type': 'application/json', 'content-length': '124', 'connection': 'keep-alive', 'x-amzn-requestid': 'a78038ec-77d7-40fa-bb19-3a966175d633'}, 'RetryAttempts': 0}, 'executionArn': 'arn:aws:bedrock:ap-northeast-1:123456789012:flow/DX8YKMNT10/alias/ZYCEKBO7NL/execution/AsyncTest-a28ce47f'}

import boto3

# Bedrock Agentランタイムクライアントの作成
session = boto3.Session(profile_name='hoge')
client = session.client('bedrock-agent-runtime', region_name='ap-northeast-1')

events_response = client.list_flow_execution_events(
    flowIdentifier='DX8YKMNT10',
    flowAliasIdentifier='ZYCEKBO7NL',
    executionIdentifier='AsyncTest-a28ce47f',
    eventType='Flow'
)

print(events_response)

{'ResponseMetadata': {'RequestId': 'd5687426-a331-4f35-92f3-2d28e30dad74', 'HTTPStatusCode': 200, 'HTTPHeaders': {'date': 'Fri, 20 Jun 2025 10:50:45 GMT', 'content-type': 'application/json', 'content-length': '657', 'connection': 'keep-alive', 'x-amzn-requestid': 'd5687426-a331-4f35-92f3-2d28e30dad74'}, 'RetryAttempts': 0}, 'flowExecutionEvents': [{'flowInputEvent': {'fields': [{'content': {'document': 'こんにちは、これは非同期実行のテストです。'}, 'name': 'document'}], 'nodeName': 'FlowInputNode', 'timestamp': datetime.datetime(2025, 6, 20, 10, 44, 2, 587651, tzinfo=tzutc())}}, {'flowOutputEvent': {'fields': [{'content': {'document': 'こんにちは！これは非同期実行のテストですね。テストが成功しているようです。何か特定の機能や情報についてテストされていますか？お手伝いできることがあれば、お気軽にお知らせください。'}, 'name': 'document'}], 'nodeName': 'FlowOutputNode', 'timestamp': datetime.datetime(2025, 6, 20, 10, 44, 6, 360120, tzinfo=tzutc())}}]}

import json
import time

def lambda_handler(event, context):
    # Sleep for 310 seconds
    time.sleep(310)
    
    # Return response with status code 200
    return 'Success'

flow-sample % poetry run python app.py
{'ResponseMetadata': {'RequestId': 'd08b92ad-5466-43f6-af67-624d44d81764', 'HTTPStatusCode': 200, 'HTTPHeaders': {'date': 'Fri, 20 Jun 2025 11:16:29 GMT', 'content-type': 'application/json', 'content-length': '124', 'connection': 'keep-alive', 'x-amzn-requestid': 'd08b92ad-5466-43f6-af67-624d44d81764'}, 'RetryAttempts': 0}, 'executionArn': 'arn:aws:bedrock:ap-northeast-1:123456789012:flow/DX8YKMNT10/alias/ZYCEKBO7NL/execution/AsyncTest-6125590c'}