As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá. # Executar exemplos de código do recurso Fluxos do Amazon Bedrock Os seguintes exemplos de código pressupõem que você atendeu a estes pré-requisitos: 1. Configurar um perfil para ter permissões para as ações do Amazon Bedrock. Se não tiver, consulte [Início rápido](getting-started.md). 1. Configurar as suas credenciais para usar a API da AWS. Se não tiver, consulte [Começar a usar a API](getting-started-api.md). 1. Criar um perfil de serviço para executar ações relacionadas ao fluxo em seu nome. Se não tiver, consulte [Criar um perfil de serviço para fluxos do Amazon Bedrock no Amazon Bedrock](flows-permissions.md). Para criar um prompt, envie uma solicitação [CreateFlow](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_CreateFlow.html) com um [endpoint de tempo de compilação do recurso Agentes para Amazon Bedrock](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt). Para obter um código de exemplo, consulte [Executar exemplos de código do recurso Fluxos do Amazon Bedrock](#flows-code-ex) Os seguintes campos são obrigatórios: **** | Campo | Descrição básica | | --- | --- | | nome | Um nome para o fluxo. | | executionRoleArn | O ARN do [perfil de serviço com permissões para criar e gerenciar fluxos](flows-permissions.md). | Os seguintes campos são opcionais: **** | Campo | Caso de uso | | --- | --- | | definição | Contém os nodes e as connections que compõem o fluxo. | | description | Para descrever o fluxo. | | tags | Para associar tags ao fluxo. Para obter mais informações, consulte [Marcação de recursos do Amazon Bedrock](tagging.md). | | customerEncryptionKeyArn | Para criptografar o recurso com uma chave do KMS. Para obter mais informações, consulte [Criptografia dos recursos do Amazon Bedrock Flows](encryption-flows.md). | | clientToken | Para garantir que a solicitação de API seja concluída apenas uma vez. Para obter mais informações, consulte [Ensuring idempotency](https://docs.aws.amazon.com/ec2/latest/devguide/ec2-api-idempotency.html). | Embora o campo `definition` seja opcional, ele é necessário para que o fluxo seja funcional. É possível escolher criar um fluxo sem a definição primeiro e, em vez disso, atualizar o fluxo posteriormente. Para cada nó na lista de `nodes`, especifique o tipo de nó no campo `type` e forneça a configuração correspondente do nó no campo `config`. Para obter detalhes sobre a estrutura da API de diferentes tipos de nó, consulte [Tipos de nó para o fluxo](flows-nodes.md). Para experimentar alguns exemplos de código para fluxos do Amazon Bedrock, escolha a guia correspondente ao método de sua preferência e siga as etapas: ------ #### [ Python ] 1. Crie um fluxo usando uma solicitação [CreateFlow](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_CreateFlow.html) com um [endpoint de tempo de compilação do recurso Agentes para Amazon Bedrock](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt) com os seguintes nós: + Um nó de entrada. + Um nó de prompt com um prompt definido em linha que cria uma playlist de músicas usando duas variáveis (`genre` e `number`). + Um nó de saída que retorna a conclusão do modelo. Execute o seguinte trecho de código para carregar o AWS SDK para Python (Boto3), crie um cliente para agentes do Amazon Bedrock e crie um fluxo com os nós (substitua o campo `executionRoleArn` pelo ARN do perfil de serviço que você criou para o fluxo): ``` # 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. Liste os fluxos em sua conta, inclusive o que você acabou de criar, executando o seguinte trecho de código para fazer uma solicitação [ListFlows](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_ListFlows.html) com um [endpoint de tempo de compilação do recurso Agentes para Amazon Bedrock](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt): ``` client.list_flows() ``` 1. Obtenha informações sobre o fluxo que você acabou de criar executando o seguinte trecho de código para fazer uma solicitação [GetFlow](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_GetFlow.html) com um [endpoint de tempo de compilação do recurso Agentes para Amazon Bedrock](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt): ``` client.get_flow(flowIdentifier=flow_id) ``` 1. Prepare o fluxo para que as alterações mais recentes do rascunho de trabalho sejam aplicadas e para que ele esteja pronto para a versão. Execute o seguinte trecho de código para fazer uma solicitação [PrepareFlow](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_PrepareFlow.html) com um [endpoint de tempo de compilação do recurso Agentes para Amazon Bedrock](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt): ``` client.prepare_flow(flowIdentifier=flow_id) ``` 1. Crie uma versão do rascunho de trabalho do fluxo para criar um snapshot estático do fluxo e recuperar informações sobre ele com as seguintes ações: 1. Crie uma versão executando o seguinte trecho de código para fazer uma solicitação [CreateFlowVersion](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_CreateFlowVersion.html) com um [endpoint de tempo de compilação do recurso Agentes para Amazon Bedrock](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt): ``` response = client.create_flow_version(flowIdentifier=flow_id) flow_version = response.get("version") ``` 1. Liste todas as versões do fluxo executando o seguinte trecho de código para fazer uma solicitação [ListFlowVersions](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_ListFlowVersions.html) com um [endpoint de tempo de compilação do recurso Agentes para Amazon Bedrock](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt): ``` client.list_flow_versions(flowIdentifier=flow_id) ``` 1. Obtenha informações sobre a versão executando o seguinte trecho de código para fazer uma solicitação [GetFlowVersion](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_GetFlowVersion.html) com um [endpoint de tempo de compilação do recurso Agentes para Amazon Bedrock](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt): ``` client.get_flow_version(flowIdentifier=flow_id, flowVersion=flow_version) ``` 1. Crie um alias para apontar para a versão do fluxo que você criou e recupere as informações sobre ele com as seguintes ações: 1. Crie um alias e aponte-o para a versão que você acabou de criar executando o seguinte trecho de código para fazer uma solicitação [CreateFlowAlias](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_CreateFlowAlias.html) com um [endpoint de tempo de compilação do recurso Agentes para Amazon Bedrock:](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt): ``` 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. Liste todos os aliases do fluxo executando o seguinte trecho de código para fazer uma solicitação [ListFlowAlias](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_ListFlowAliass.html) com um [endpoint de tempo de compilação do recurso Agentes para Amazon Bedrock](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt): ``` client.list_flow_aliases(flowIdentifier=flow_id) ``` 1. Obtenha informações sobre o alias que você acabou de criar executando o seguinte trecho de código para fazer uma solicitação [GetFlowAlias](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_GetFlowAlias.html) com um [endpoint de tempo de compilação do recurso Agentes para Amazon Bedrock](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt): ``` client.get_flow_alias(flowIdentifier=flow_id, aliasIdentifier=flow_alias_id) ``` 1. Execute o trecho de código a seguir para criar um cliente do Amazon Bedrock Agents Runtime e invoque um fluxo. A solicitação preenche as variáveis no prompt no fluxo e exibe a resposta do modelo para fazer uma solicitação [InvokeFlow](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent-runtime_InvokeFlow.html) com um [endpoint de runtime do recurso Agentes para Amazon Bedrock](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-rt): ``` 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']) ``` A resposta deve apresentar uma playlist com três músicas pop. 1. Exclua o alias, a versão e o fluxo que você criou com as seguintes ações: 1. Exclua o alias executando o seguinte trecho de código para fazer uma solicitação [DeleteFlowAlias](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_DeleteFlowAlias.html) com um [endpoint de tempo de compilação do recurso Agentes para Amazon Bedrock](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt): ``` client.delete_flow_alias(flowIdentifier=flow_id, aliasIdentifier=flow_alias_id) ``` 1. Exclua a versão executando o seguinte trecho de código para fazer uma solicitação [DeleteFlowVersion](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_DeleteFlowVersion.html) com um [endpoint de tempo de compilação do recurso Agentes para Amazon Bedrock](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt): ``` client.delete_flow_version(flowIdentifier=flow_id, flowVersion=flow_version) ``` 1. Exclua o fluxo executando o seguinte trecho de código para fazer uma solicitação [DeleteFlow](https://docs.aws.amazon.com/bedrock/latest/APIReference/API_agent_DeleteFlow.html) com um [endpoint de tempo de compilação do recurso Agentes para Amazon Bedrock](https://docs.aws.amazon.com/general/latest/gr/bedrock.html#bra-bt): ``` client.delete_flow(flowIdentifier=flow_id) ``` ------