Iniciar uma execução de fluxo
Para executar uma execução de fluxo, envie uma StartFlowExecutionsolicitação com um endpoint de tempo de execução do Agents for Amazon Bedrock. Na solicitação, especifique o ID do fluxo e o ID do alias do fluxo que você deseja executar. Também é possível especificar o seguinte:
-
inputs — Uma matriz contendo o nó de entrada a partir do qual você deseja que o fluxo comece a ser executado. Você especifica a entrada a ser enviada para o nó de entrada de fluxo imediato no content campo.
-
name — Um nome para a execução do fluxo.
{
"inputs": [{
"nodeName": "FlowInputNode",
"nodeOutputName": "document",
"content": {
"document": "Test"
}
}],
"name": "MyExecution"
}
A resposta é o Amazon Resource Name (ARN) da execução do fluxo. Você pode usar o executionArn para pesquisar o estado atual do fluxo, como quando a execução do fluxo termina ou um nó de condição avalia suas condições.
{
"executionArn": "arn:aws:bedrock:us-west-2:111122223333:flow/FLOWID/alias/TSTALIASID/execution/MyExecution"
}
Acompanhe o progresso da execução de um fluxo
Use a GetFlowExecutionoperação para obter o status atual de um fluxo que você identifica pelo ARN de execução. O status do fluxo é RunningSucceeded,Failed,TimedOut, ouAborted.
{
"endedAt": null,
"errors": null,
"executionArn": "arn:aws:bedrock:us-west-2:111122223333:flow/FLOWID/alias/TSTALIASID/execution/MyExecution",
"flowAliasIdentifier": "TSTALIASID",
"flowIdentifier": "FLOWID",
"flowVersion": "DRAFT",
"startedAt": "2025-03-20T23:32:28.899221162Z",
"status": "Running"
}
Erros (como um nó Lambda que atinge o tempo limite) são retornados na errors matriz, como no exemplo a seguir:
"errors": [{
"nodeName": "LambdaNode1",
"errorType": "ExecutionTimedOut",
"message": "Call to lambda function timed out"
}],
Obtenha os resultados de uma execução de fluxo
O Amazon Bedrock grava as saídas de um fluxo nos nós de saída do fluxo. Você pode obter as saídas quando o fluxo for concluído ou enquanto o fluxo estiver em execução (dependendo do seu caso de uso).
Se você quiser que o fluxo seja concluído primeiro, faça uma chamada para GetFlowExecution e certifique-se de que o valor do status campo na resposta sejaSucceeded.
Para obter uma lista de eventos de saída da execução do fluxo, faça uma chamada para ListFlowExecutionEvents. Na resposta, verifique se há flowOutputEvent objetos dentroflowExecutionEvents. Por exemplo, você pode obter a saída de um fluxo no content campo:
{
"flowOutputEvent": {
"content": {
"document": "The model response."
},
"nodeName": "FlowOutputNode"
}
}
Você pode limitar a saída de ListFlowExecutions apenas nós de entrada e saída definindo o parâmetro de eventType consulta comoFlow.
Visualizar eventos
Para ajudar a depurar a execução do fluxo, você pode usar a ListFlowExecutionEventsoperação para visualizar os eventos que os nós geram enquanto o fluxo está em execução. Defina o parâmetro de eventType consulta Node para ver as entradas e saídas de todos os nós (incluindo nós intermediários) na resposta, semelhante ao exemplo a seguir:
{
"flowExecutionEvents": [{
"nodeOutputEvent": {
"fields": [{
"content": {
"document": "History book"
},
"name": "document"
}],
"nodeName": "FlowInputNode",
"timestamp": "2025-05-05T18:38:56.637867516Z"
}
},
{
"nodeInputEvent": {
"fields": [{
"content": {
"document": "History book"
},
"name": "book"
}],
"nodeName": "Prompt_1",
"timestamp": "2025-05-05T18:38:57.434600163Z"
}
},
{
"nodeOutputEvent": {
"fields": [{
"content": {
"document": "Here's a summary of the history book."
},
"name": "modelCompletion"
}],
"nodeName": "Prompt_1",
"timestamp": "2025-05-05T18:39:06.034157077Z"
}
},
{
"nodeInputEvent": {
"fields": [{
"content": {
"document": "Here's a summary of the history book."
},
"name": "document"
}],
"nodeName": "FlowOutputNode",
"timestamp": "2025-05-05T18:39:06.453128251Z"
}
}
]
}
Obtenha um instantâneo da execução do seu fluxo
O Amazon Bedrock tira automaticamente um instantâneo de uma definição de fluxo e metadados quando a execução de um fluxo é iniciada. Isso é útil, pois um fluxo pode ser atualizado enquanto está sendo executado de forma assíncrona. Para recuperar esse instantâneo, chame a GetExecutionFlowSnapshotoperação. A resposta inclui os seguintes campos de fluxo:
-
customerEncryptionKeyArn — O ARN da chave que AWS KMS criptografa o fluxo.
-
definição — A definição do fluxo.
-
executionRoleArn— O ARN da função de serviço do IAM que é usada pela execução do fluxo.
-
flowAliasIdentifier— O ID do alias do fluxo.
-
FlowIdentifier — O ID do fluxo.
-
flowVersion — A versão do fluxo.
{
"customerEncryptionKeyArn": null,
"definition": "{flow-definition}",
"executionRoleArn": "arn:aws:iam::111122223333:role/name",
"flowAliasIdentifier": "TSTALIASID",
"flowIdentifier": "FLOWID",
"flowVersion": "DRAFT"
}
Liste suas execuções de fluxo
Você pode obter uma lista de suas execuções de fluxo chamando a ListFlowExecutionsoperação. A resposta inclui uma flowExecutionSummaries matriz com informações sobre cada uma de suas execuções de fluxo na corrente Região da AWS para um fluxo ou alias de fluxo. Cada elemento inclui informações como o ARN da execução, a hora de início e o status atual do fluxo.
{
"flowExecutionSummaries": [{
"createdAt": "2025-03-11T23:21:02.875598966Z",
"endedAt": null,
"executionArn": "arn:aws:bedrock:us-west-2:111122223333:flow/FLOWID/alias/TSTALIASID/execution/MyExecution",
"flowAliasIdentifier": "TSTALIASID",
"flowIdentifier": "FLOWID",
"flowVersion": "DRAFT",
"status": "Running"
}]
}
Interromper a execução de um fluxo em execução
Se você precisar interromper a execução de um fluxo em execução, chame a StopFlowExecutionoperação e passe o ID do fluxo, o ID do alias do fluxo e o ID de execução do fluxo para a execução que você deseja interromper.
