翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。 # Amazon Bedrock フローのコードサンプルを実行する 次のコードサンプルは、次の前提条件を満たしていることを前提としています。 1. Amazon Bedrock アクションへのアクセス許可を持つロールを設定する。設定していない場合は、「[クイックスタート](getting-started.md)」を参照します。 1. AWS API を使用するように認証情報を設定する。設定していない場合は、「[API の使用を開始する](getting-started-api.md)」を参照します。 1. サービスロールを作成して、ユーザーに代わってフロー関連のアクションを実行する。設定していない場合は、「[Amazon Bedrock で Amazon Bedrock Flows のサービスロールを作成する](flows-permissions.md)」を参照します。 フローを作成するには、[Amazon Bedrock エージェントのビルドタイムエンドポイント](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt)を使用して、[CreateFlow](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_CreateFlow.html) リクエストを送信します。サンプルコードについては、「[Amazon Bedrock フローのコードサンプルを実行する](#flows-code-ex)」を参照してください。 以下のフィールドが必要です。 **** | フィールド | 基本的な説明 | | --- | --- | | 名前 | フローの名前。 | | executionRoleArn | [フローを作成して管理するためのアクセス許可を持つサービスロールの ARN](flows-permissions.md)。 | 次のフィールドはオプションです。 **** | フィールド | ユースケース | | --- | --- | | 定義 | フローを構成する nodes と connections が含まれます。 | | description | フローについて記述する場合に指定します。 | | tags | タグをエイリアスに関連付ける場合に指定します。詳細については、「[Amazon Bedrock リソースにタグ付け](tagging.md)」を参照してください。 | | customerEncryptionKeyArn | KMS キーを使用してリソースを暗号化する場合に指定します。詳細については、「[Amazon Bedrock Flows リソースの暗号化](encryption-flows.md)」を参照してください。 | | clientToken | API リクエストが 1 回だけ完了するようにします。詳細については、「[べき等性の確保](https://docs.aws.amazon.com/ec2/latest/devguide/ec2-api-idempotency.html)」を参照してください。 | `definition` フィールドはオプションですが、フローが機能するために必要です。定義なしでフローを作成し、後でフローを更新することもできます。 `nodes` リスト内のノードごとに、`type` フィールドでノードのタイプを指定し、`config` フィールドでノードの対応する設定を指定します。さまざまなタイプのノードの API 構造の詳細については、「[フローのノードタイプ](flows-nodes.md)」を参照してください。 Amazon Bedrock フローのコードサンプルを試すには、任意の方法のタブを選択してステップを実行してください。 ------ #### [ Python ] 1. 次のノードについて、[Amazon Bedrock エージェントのビルドタイムエンドポイント](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt)で [CreateFlow](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_CreateFlow.html) リクエストを使用してフローを作成します。 + 入力ノード。 + 2 つの変数 (`genre` と `number`) を使用して音楽プレイリストを作成するプロンプトがインラインで定義されているプロンプトノード。 + モデルの完了を返す出力ノード。 次のコードスニペットを実行して AWS SDK for Python (Boto3) をロードし、Amazon Bedrock エージェントクライアントを作成して、ノードでフローを作成します (`executionRoleArn` フィールドをフロー用に作成したサービスロールの ARN に置き換えます)。 ``` # Import Python SDK and create client import boto3 client = boto3.client(service_name='bedrock-agent') # Replace with the service role that you created. For more information, see https://docs.aws.amazon.com/bedrock/latest/userguide/flows-permissions.html FLOWS_SERVICE_ROLE = "arn:aws:iam::123456789012:role/MyFlowsRole" # Define each node # The input node validates that the content of the InvokeFlow request is a JSON object. input_node = { "type": "Input", "name": "FlowInput", "outputs": [ { "name": "document", "type": "Object" } ] } # This prompt node defines an inline prompt that creates a music playlist using two variables. # 1. {{genre}} - The genre of music to create a playlist for # 2. {{number}} - The number of songs to include in the playlist # It validates that the input is a JSON object that minimally contains the fields "genre" and "number", which it will map to the prompt variables. # The output must be named "modelCompletion" and be of the type "String". prompt_node = { "type": "Prompt", "name": "MakePlaylist", "configuration": { "prompt": { "sourceConfiguration": { "inline": { "modelId": "amazon.nova-lite-v1:0", "templateType": "TEXT", "inferenceConfiguration": { "text": { "temperature": 0.8 } }, "templateConfiguration": { "text": { "text": "Make me a {{genre}} playlist consisting of the following number of songs: {{number}}." } } } } } }, "inputs": [ { "name": "genre", "type": "String", "expression": "$.data.genre" }, { "name": "number", "type": "Number", "expression": "$.data.number" } ], "outputs": [ { "name": "modelCompletion", "type": "String" } ] } # The output node validates that the output from the last node is a string and returns it as is. The name must be "document". output_node = { "type": "Output", "name": "FlowOutput", "inputs": [ { "name": "document", "type": "String", "expression": "$.data" } ] } # Create connections between the nodes connections = [] # First, create connections between the output of the flow input node and each input of the prompt node for input in prompt_node["inputs"]: connections.append( { "name": "_".join([input_node["name"], prompt_node["name"], input["name"]]), "source": input_node["name"], "target": prompt_node["name"], "type": "Data", "configuration": { "data": { "sourceOutput": input_node["outputs"][0]["name"], "targetInput": input["name"] } } } ) # Then, create a connection between the output of the prompt node and the input of the flow output node connections.append( { "name": "_".join([prompt_node["name"], output_node["name"]]), "source": prompt_node["name"], "target": output_node["name"], "type": "Data", "configuration": { "data": { "sourceOutput": prompt_node["outputs"][0]["name"], "targetInput": output_node["inputs"][0]["name"] } } } ) # Create the flow from the nodes and connections response = client.create_flow( name="FlowCreatePlaylist", description="A flow that creates a playlist given a genre and number of songs to include in the playlist.", executionRoleArn=FLOWS_SERVICE_ROLE, definition={ "nodes": [input_node, prompt_node, output_node], "connections": connections } ) flow_id = response.get("id") ``` 1. 次のコードスニペットを実行し、[Amazon Bedrock エージェントのビルドタイムエンドポイント](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt)を使用して [ListFlows](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_ListFlows.html) リクエストを行い、作成したフローを含めて、アカウント内のフローを一覧表示します。 ``` client.list_flows() ``` 1. 次のコードスニペットを実行して [Amazon Bedrock エージェントのビルドタイムエンドポイント](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt)で [GetFlow](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_GetFlow.html) リクエストを行い、作成したフローに関する情報を取得します。 ``` client.get_flow(flowIdentifier=flow_id) ``` 1. 作業中のドラフトから最新の変更が適用されるように、またバージョン管理の準備が整うようにフローを準備してください。次のコードスニペットを実行し、[Amazon Bedrock エージェントのビルドタイムエンドポイント](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt)を使用して [PrepareFlow](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_PrepareFlow.html) リクエストを行います。 ``` client.prepare_flow(flowIdentifier=flow_id) ``` 1. フローに関する作業中のドラフトのバージョン管理を行い、フローの静的スナップショットを作成し、次のアクションを実行してそのスナップショットに関する情報を取得します。 1. 次のコードスニペットを実行し、[Amazon Bedrock エージェントのビルドタイムエンドポイント](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt)を使用して [CreateFlowVersion](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_CreateFlowVersion.html) リクエストを行い、バージョンを作成します。 ``` response = client.create_flow_version(flowIdentifier=flow_id) flow_version = response.get("version") ``` 1. 次のコードスニペットを実行し、[Amazon Bedrock エージェントのビルドタイムエンドポイント](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt)を使用して [ListFlowVersions](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_ListFlowVersions.html) リクエストを行い、フローのバージョンをすべて一覧表示します。 ``` client.list_flow_versions(flowIdentifier=flow_id) ``` 1. 次のコードスニペットを実行し、[Amazon Bedrock エージェントのビルドタイムエンドポイント](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt)を使用して [GetFlowVersion](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_GetFlowVersion.html) リクエストを行い、バージョンに関する情報を取得します。 ``` client.get_flow_version(flowIdentifier=flow_id, flowVersion=flow_version) ``` 1. 作成したフローのバージョンを指すエイリアスを作成して、次のアクションでこれに関する情報を取得します。 1. 次のコードスニペットを実行し、[Amazon Bedrock エージェントのビルドタイムエンドポイント](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt)を使用して [CreateFlowAlias](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_CreateFlowAlias.html) リクエストを行い、エイリアスを作成し、作成したバージョンを指します。 ``` response = client.create_flow_alias( flowIdentifier=flow_id, name="latest", description="Alias pointing to the latest version of the flow.", routingConfiguration=[ { "flowVersion": flow_version } ] ) flow_alias_id = response.get("id") ``` 1. 次のコードスニペットを実行し、[Amazon Bedrock エージェントのビルドタイムエンドポイント](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt)を使用して [ListFlowAliass](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_ListFlowAliass.html) リクエストを行い、フローのエイリアスをすべて一覧表示します。 ``` client.list_flow_aliases(flowIdentifier=flow_id) ``` 1. 次のコードスニペットを実行し、[Amazon Bedrock エージェントのビルドタイムエンドポイント](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt)を使用して [GetFlowAlias](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_GetFlowAlias.html) リクエストを行い、作成したエイリアスに関する情報を取得します。 ``` client.get_flow_alias(flowIdentifier=flow_id, aliasIdentifier=flow_alias_id) ``` 1. 次のコードスニペットを実行して、Amazon Bedrock Agents Runtime クライアントを作成し、フローを呼び出します。このリクエストにより、フローのプロンプトに変数が埋められ、モデルから応答が返されて、[Amazon Bedrock エージェントのランタイムエンドポイント](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-rt)を使用して [InvokeFlow](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent-runtime_InvokeFlow.html) リクエストが行われます。 ``` client_runtime = boto3.client('bedrock-agent-runtime') response = client_runtime.invoke_flow( flowIdentifier=flow_id, flowAliasIdentifier=flow_alias_id, inputs=[ { "content": { "document": { "genre": "pop", "number": 3 } }, "nodeName": "FlowInput", "nodeOutputName": "document" } ] ) result = {} for event in response.get("responseStream"): result.update(event) if result['flowCompletionEvent']['completionReason'] == 'SUCCESS': print("Flow invocation was successful! The output of the flow is as follows:\n") print(result['flowOutputEvent']['content']['document']) else: print("The flow invocation completed because of the following reason:", result['flowCompletionEvent']['completionReason']) ``` 応答は、3 曲で構成されるポップミュージックのプレイリストを返す必要があります。 1. 次のアクションを実行して作成したエイリアス、バージョン、フローを削除します。 1. 次のコードスニペットを実行し、[Amazon Bedrock エージェントのビルドタイムエンドポイント](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt)を使用して [DeleteFlowAlias](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_DeleteFlowAlias.html) リクエストを行い、エイリアスを削除します。 ``` client.delete_flow_alias(flowIdentifier=flow_id, aliasIdentifier=flow_alias_id) ``` 1. 次のコードスニペットを実行し、[Amazon Bedrock エージェントのビルドタイムエンドポイント](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt)を使用して [DeleteFlowVersion](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_DeleteFlowVersion.html) リクエストを行い、バージョンを削除します。 ``` client.delete_flow_version(flowIdentifier=flow_id, flowVersion=flow_version) ``` 1. 次のコードスニペットを実行し、[Amazon Bedrock エージェントのビルドタイムエンドポイント](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt)を使用して [DeleteFlow](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_DeleteFlow.html) リクエストを行い、フローを削除します。 ``` client.delete_flow(flowIdentifier=flow_id) ``` ------