Uma aplicação GenAI em produção raramente termina com uma única chamada ao modelo: ela extrai um documento, resume, verifica a segurança, espera a aprovação de uma pessoa e só então publica o resultado. O guia oficial do AIP-C01 cita o AWS Step Functions em 11 habilidades diferentes para esse tipo de fluxo.
Agents vs Flows vs Step Functions
| Ferramenta | Quem decide o próximo passo | Use quando | |------------|-----------------------------|------------| | Bedrock Agents | O modelo, em tempo de execução | O modelo deve escolher qual API chamar | | Amazon Bedrock Flows | O desenvolvedor, visualmente | São necessárias cadeias de prompts sem código | | AWS Step Functions | O desenvolvedor, como máquina de estados | Ordem fixa, auditoria, novas tentativas ou aprovação humana |
Aprovações humanas podem levar dias, por isso exigem um fluxo Standard (até 1 ano). Fluxos Express duram no máximo 5 minutos e não suportam .
Invocar o Bedrock sem Lambda
A integração otimizada chama o modelo diretamente do fluxo. Como o estado aceita apenas 256 KiB, os campos e recebem uma URI do S3 para documentos grandes.
Mecanismos de segurança
com , e para que as novas tentativas por throttling não cheguem todas ao mesmo tempo para um estado de fallback: um modelo menor ou uma resposta segura e um contador de iterações com como condição de parada Circuit breaker: gravar o estado de falhas no DynamoDB e pular a chamada ao modelo enquanto estiver aberto
Revisão humana com .waitForTaskToken
A tarefa de revisão envia o token ao revisor (SNS, uma interface interna). A execução fica pausada até que uma Lambda atrás do API Gateway chame ou . Não confunda com o Amazon A2I, que cria revisões humanas quando uma previsão de ML tem baixa confiança.
!Fluxo GenAI no Step Functions com revisão humana
Pontos-chave para o exame
"Fluxo GenAI com ordem fixa, auditoria e novas tentativas" -- AWS Step Functions (Standard) "O modelo decide qual ferramenta usar" -- Bedrock Agents "Cadeias de prompts sem código" -- Amazon Bedrock Flows "Entrada ou saída maior que 256 KiB" -- Input/Output com S3Uri "Pausar até a aprovação de um revisor" -- .waitForTaskToken + SendTaskSuccess "Processar dezenas de milhares de documentos" -- Distributed Map (até 10.000 execuções em paralelo) "Mesma entrada para vários modelos ao mesmo tempo" -- Estado Parallel "Parar de chamar um modelo que está falhando" -- Circuit breaker (DynamoDB + Choice)