Step Functions: orchestrazione dei flussi di lavoro serverless

AWS Step Functions è un servizio completamente gestito per l'orchestrazione dei workflow, che coordina applicazioni distribuite come una serie di passaggi definiti in una macchina a stati. Ogni passaggio della macchina a stati è uno stato: un'invocazione Lambda, una chiamata AWS SDK, un periodo di attesa, un ramo parallelo o una scelta (if/else). Step Functions gestisce lo stato, i tentativi e fornisce una cronologia visiva delle esecuzioni, eliminando la necessità di scrivere la logica di orchestrazione nel codice dell'applicazione.

Le macchine a stati sono definite in Amazon States Language (ASL), un linguaggio basato su JSON. Ogni stato ha un Type (Task, Choice, Wait, Parallel, Map, Pass, Succeed, Fail) e passa a uno stato Next oppure termina. Il campo Resource di uno stato Task specifica il servizio AWS da richiamare: un ARN per Lambda oppure un ARN di integrazione ottimizzata del servizio per oltre 200 servizi AWS, senza una Lambda intermedia.

Step Functions offre due tipi di workflow. Workflow Standard: durevoli, con durata fino a 1 anno, semantica di esecuzione esattamente una volta e cronologia completa dell'esecuzione conservata per 90 giorni; sono adatti ai processi aziendali di lunga durata. Workflow Express: throughput elevato (oltre 100.000 esecuzioni al secondo), durata fino a 5 minuti, semantica almeno una volta e log inviati a CloudWatch; sono adatti all'elaborazione di eventi in tempo reale e alle pipeline di dati IoT. Scelga in base ai requisiti di durata, throughput e idempotenza.

Gli stati Task di Step Functions supportano due pattern di integrazione. Request-Response: richiama un servizio AWS e procede immediatamente (fire-and-forget). Integrazione sincrona: richiama un servizio e attende il completamento prima di passare allo stato successivo (ad esempio, attende il completamento di un task ECS, di un job Glue o di un job di addestramento SageMaker). L'integrazione sincrona usa il suffisso :sync:2 nell'ARN della risorsa ed elimina la necessità della logica di polling.

Uno stato Choice implementa una diramazione condizionale, equivalente in un workflow a un'istruzione if/else o switch. Definisce Choices come array di condizioni; la prima condizione corrispondente determina lo stato successivo. Uno stato Default gestisce i casi senza corrispondenza. Gli stati Choice consentono di instradare un ordine verso diversi percorsi di evasione in base al tipo di prodotto, alla categoria del cliente o allo stato del pagamento, senza scrivere logica condizionale in Lambda.

Uno stato Parallel esegue più rami contemporaneamente e attende che tutti siano completati prima di proseguire, risultando utile per attività concorrenti come eseguire contemporaneamente un controllo del credito e un controllo dell'inventario. Uno stato Map itera su un array nell'input e applica lo stesso insieme di stati a ogni elemento in parallelo; è utile per elaborare un batch di elementi restituiti da un passaggio precedente, ad esempio per ridimensionare più immagini caricate.

Ogni stato Task in Step Functions può includere blocchi Retry e Catch per una gestione resiliente degli errori. Retry specifica quali tipi di errore attivano automaticamente nuovi tentativi, con IntervalSeconds, MaxAttempts e BackoffRate configurabili (moltiplicatore del backoff esponenziale). Catch specifica gli stati di fallback per gli errori non recuperabili. Questa gestione dichiarativa degli errori evita blocchi try/catch ripetitivi all'interno delle funzioni Lambda.

Uno stato Wait sospende l'esecuzione del workflow per una durata fissa o fino a uno specifico timestamp. Un pattern Callback (che usa .waitForTaskToken) sospende l'esecuzione finché un sistema esterno non chiama SendTaskSuccess o SendTaskFailure con il token. In questo modo Step Functions modella i passaggi di approvazione umana: invia un'email con il token dell'attività e il workflow riprende quando una persona fa clic sul link di approvazione o rifiuto nel proprio client email.

Le esecuzioni di Step Functions possono essere avviate dalle regole EventBridge, semplificando l'attivazione dei workflow in risposta agli eventi dei servizi AWS. Ad esempio, un evento S3 ObjectCreated attiva una regola EventBridge che avvia un workflow Step Functions per l'elaborazione delle immagini. Step Functions può anche pubblicare i propri eventi su EventBridge quando le esecuzioni hanno esito positivo o negativo, consentendo il monitoraggio e gli avvisi a valle senza eseguire il polling dell'API Step Functions.

La console Step Functions fornisce un diagramma visivo dell'esecuzione del workflow che mostra quale stato è riuscito, quale è in esecuzione e quale ha avuto esito negativo, con colori distintivi in tempo reale. Ogni esecuzione conserva la cronologia completa di input e output per i workflow Standard (conservazione di 90 giorni). Per i workflow Express, i log vengono inviati a CloudWatch Logs. Usi il tracing X-Ray per tracciare la latenza end-to-end delle richieste tra le funzioni Lambda e gli altri servizi chiamati nel workflow.

Capire quando usare Step Functions anziché SQS o EventBridge è un caso frequente nelle domande d'esame. Usi Step Functions quando è necessaria un'orchestrazione visibile e con stato di un processo composto da più passaggi, con gestione degli errori e diramazioni. Usi SQS per una messaggistica asincrona point-to-point affidabile tra due servizi, con nuovi tentativi tramite il visibility timeout. Usi EventBridge per instradare gli eventi verso più sottoscrittori in base a pattern del contenuto. Un workflow Step Functions può integrare tutti e tre: attendere un messaggio SQS tramite un token dell'attività, pubblicare il completamento su EventBridge e concatenare chiamate Lambda e SDK.

Verifichi la Sua comprensione dei concetti di AWS Solutions Architect (SAA-C03) trattati in questa lezione.

In questa lezione ha imparato che: Step Functions orchestra i flussi di lavoro come macchine a stati con gli stati Task, Choice, Parallel, Map, Wait e Catch, i flussi di lavoro Standard supportano una durata massima di 1 anno con la cronologia completa delle esecuzioni, mentre i flussi di lavoro Express gestiscono carichi ad alto throughput di durata inferiore a 5 minuti e il pattern Callback con i token delle attività consente di implementare fasi di approvazione con coinvolgimento umano. Ora analizzeremo Kinesis Data Streams per l'elaborazione di eventi in tempo reale ad alto throughput.