Step Functions: orquestração de fluxos de trabalho sem servidor

AWS Step Functions é um serviço totalmente gerenciado de orquestração de fluxos de trabalho que coordena aplicações distribuídas como uma série de etapas definidas em uma máquina de estados. Cada etapa da máquina de estados é um estado — uma invocação de Lambda, uma chamada do AWS SDK, um período de espera, uma ramificação paralela ou uma escolha (if/else). O Step Functions gerencia o estado, trata novas tentativas e fornece um histórico visual de execução, eliminando a necessidade de escrever a lógica de orquestração no código da aplicação.

As máquinas de estados são definidas na Amazon States Language (ASL), uma linguagem baseada em JSON. Cada estado tem um Type (Task, Choice, Wait, Parallel, Map, Pass, Succeed, Fail) e faz a transição para um estado Next ou termina. O campo Resource de um estado Task especifica o serviço da AWS a ser invocado — um ARN para Lambda ou um ARN de integração de serviço otimizado para mais de 200 serviços da AWS, sem uma Lambda intermediária.

O Step Functions tem dois tipos de fluxo de trabalho. Fluxos de trabalho Standard: duráveis, com duração de até 1 ano, semântica de execução exatamente uma vez e histórico completo de execução armazenado por 90 dias — adequados para processos empresariais de longa duração. Fluxos de trabalho Express: alto volume (mais de 100.000 execuções por segundo), duração de até 5 minutos, semântica de pelo menos uma vez e registros enviados ao CloudWatch — adequados para processamento de eventos em tempo real e fluxos de dados de IoT. Escolha com base na duração, no volume e nos requisitos de idempotência.

Os estados Task do Step Functions oferecem suporte a dois padrões de integração. Solicitação-resposta: chama um serviço da AWS e prossegue imediatamente (disparar e esquecer). Integração Sync: chama um serviço e aguarda sua conclusão antes de avançar para o próximo estado (por exemplo, aguardar o término de uma tarefa do ECS, a conclusão de um trabalho do Glue ou o fim de um trabalho de treinamento do SageMaker). A integração Sync usa o sufixo :sync:2 no ARN do recurso e elimina a necessidade de lógica de consulta periódica.

Um estado Choice implementa uma ramificação condicional — o equivalente, em um fluxo de trabalho, a uma instrução if/else ou switch. Você define Choices como uma matriz de condições; a primeira condição correspondente determina o próximo estado. Um estado Default trata os casos sem correspondência. Os estados Choice permitem encaminhar um pedido por diferentes caminhos de atendimento com base no tipo de produto, no nível do cliente ou no status do pagamento, sem escrever lógica condicional em uma Lambda.

Um estado Parallel executa várias ramificações simultaneamente e aguarda a conclusão de todas antes de prosseguir — útil para tarefas simultâneas, como executar uma verificação de crédito e uma verificação de estoque ao mesmo tempo. Um estado Map percorre uma matriz na entrada e aplica o mesmo conjunto de estados a cada elemento em paralelo — útil para processar um lote de itens retornados por uma etapa anterior, como redimensionar várias imagens carregadas.

Todo estado Task do Step Functions pode ter blocos Retry e Catch para um tratamento resiliente de erros. Retry especifica quais tipos de erro acionam novas tentativas automáticas com IntervalSeconds, MaxAttempts e BackoffRate configuráveis (multiplicador de espera progressiva exponencial). Catch especifica estados de fallback para erros irrecuperáveis. Esse tratamento declarativo de erros evita blocos try/catch repetitivos dentro das funções Lambda.

Um estado Wait pausa a execução do fluxo de trabalho por uma duração fixa ou até um registro de data e hora específico. Um padrão de Callback (usando .waitForTaskToken) pausa a execução até que um sistema externo chame SendTaskSuccess ou SendTaskFailure com o token. É assim que o Step Functions modela etapas de aprovação humana: envia um e-mail com o token da tarefa, e o fluxo de trabalho é retomado quando uma pessoa clica em um link de aprovação ou rejeição no cliente de e-mail.

As execuções do Step Functions podem ser iniciadas por regras do EventBridge, facilitando o acionamento de fluxos de trabalho em resposta a eventos de serviços da AWS. Por exemplo, um evento ObjectCreated do S3 aciona uma regra do EventBridge que inicia um fluxo de trabalho do Step Functions para processamento de imagens. O Step Functions também pode publicar seus próprios eventos no EventBridge quando as execuções são bem-sucedidas ou falham, permitindo monitoramento e alertas posteriores sem consultar a API do Step Functions periodicamente.

O console do Step Functions fornece um diagrama visual de execução do fluxo de trabalho que mostra qual estado foi concluído, qual está em execução e qual falhou — com cores atualizadas em tempo real. Cada execução armazena todo o seu histórico de entrada e saída nos fluxos de trabalho Standard (retenção de 90 dias). Nos fluxos de trabalho Express, os registros são enviados ao CloudWatch Logs. Use o rastreamento do X-Ray para acompanhar a latência de solicitações de ponta a ponta entre funções Lambda e outros serviços chamados no fluxo de trabalho.

Saber quando usar o Step Functions em vez de SQS ou EventBridge é uma decisão comum em exames. Use o Step Functions quando precisar de uma orquestração visível e com estado para um processo com várias etapas, tratamento de erros e ramificações. Use o SQS para mensagens assíncronas confiáveis ponto a ponto entre dois serviços, com novas tentativas por meio do tempo limite de visibilidade. Use o EventBridge para encaminhar eventos a vários assinantes com base em padrões de conteúdo. Um fluxo de trabalho do Step Functions pode integrar os três: aguardar uma mensagem do SQS por meio de um token de tarefa, publicar a conclusão no EventBridge e encadear chamadas de Lambda e do SDK.

Teste sua compreensão dos conceitos de AWS Solutions Architect (SAA-C03) desta lição.

Nesta lição, você aprendeu que: Step Functions orquestra fluxos de trabalho como máquinas de estado com estados Task, Choice, Parallel, Map, Wait e Catch; os fluxos de trabalho Standard oferecem suporte de até 1 ano com histórico completo de execução, enquanto os fluxos de trabalho Express lidam com cargas de trabalho de alta taxa de transferência com duração inferior a 5 minutos; e o padrão Callback com tokens de tarefa permite etapas de aprovação com participação humana. Em seguida, exploraremos Kinesis Data Fluxos para processamento de eventos em tempo real com alta taxa de transferência.