Scopri come iniziare a usare Step Functions

Con il servizio Step Functions, puoi orchestrare flussi di lavoro applicativi complessi. Per iniziare, utilizzerai Workflow Studio per creare ed eseguire un flusso di lavoro Hello World integrato. Esaminerai la definizione generata automaticamente Amazon States Language (ASL) nel codice. Infine, avrai drag-and-drop un'integrazione di servizi per eseguire l'analisi del sentiment.

Dopo aver completato questo tutorial, saprete come utilizzare Workflow Studio per creare, configurare, eseguire e aggiornare un flusso di lavoro utilizzando le modalità Progettazione e Codice.

Durata stimata: 20-30 minuti

Cosa costruirai

La tua prima macchina a stati inizierà con gli stati di flusso. Gli stati di flusso vengono utilizzati per dirigere e controllare il flusso di lavoro. Dopo aver appreso come eseguire il flusso di lavoro, aggiungerai un'azione per integrare il servizio Amazon Comprehend con uno stato Task.

Il diagramma seguente mostra un'immagine della macchina a stati completa che costruirai. La prima volta che crei la macchina a stati Hello World, non avrai bisogno di risorse aggiuntive per funzionare. La console Step Functions creerà tutti gli stati e un ruolo IAM con un solo clic. Successivamente, quando aggiungerai l'integrazione del servizio, dovrai creare un ruolo con una politica di autorizzazione personalizzata.

Fase 1 - Crea la tua macchina a stati

In Step Functions, i flussi di lavoro sono chiamati macchine a stati. Useremo entrambi i termini in modo intercambiabile. I tuoi flussi di lavoro conterranno stati che agiscono o controllano il flusso delle tue macchine a stati.

Panoramica di Workflow Studio

Con Workflow Studio for Step Functions, puoi visualizzare drag-and-drop gli stati su una tela per creare flussi di lavoro.

È possibile aggiungere e modificare stati, configurare passaggi, trasformare i risultati e impostare la gestione degli errori. La schermata seguente mostra quattro aree importanti dell'interfaccia che utilizzerete per creare le vostre macchine a stati.

Modalità: Workflow Studio offre tre modalità operative e l'impostazione predefinita è la modalità di progettazione visiva.

Il browser States contiene le seguenti tre schede:

La tela e il grafico del flusso di lavoro consentono di drag-and-drop visualizzare gli stati del grafico del flusso di lavoro, modificare l'ordine degli stati e selezionare gli stati da configurare e testare.

Il pannello Inspector consente di visualizzare e modificare le proprietà di qualsiasi stato selezionato nell'area di disegno. È possibile attivare l'interruttore Definizione per mostrare il codice per lo stato attualmente selezionato.

Panoramica della macchina a stati

Il flusso di lavoro Hello World inizia con uno stato Pass che trasmette l'input all'output, senza eseguire alcuna operazione. Gli stati Pass possono essere utilizzati per generare un output JSON statico o trasformare l'input JSON prima di passare i dati allo stato successivo. Gli stati di passaggio sono utili per la costruzione e il debug di macchine a stati.

Lo stato successivo, uno stato Choice, utilizza i dati in ingresso IsHelloWorldExample per scegliere il ramo successivo del flusso di lavoro. Se la prima regola corrisponde, il flusso di lavoro viene sospeso in uno stato di attesa, quindi esegue due attività in uno stato Parallelo, prima di passare a un checkpoint e alla conclusione corretta del flusso di lavoro. Quando non vi è alcuna corrispondenza, il flusso di lavoro passa per impostazione predefinita allo stato Fail prima di arrestare la macchina a stati.

Gli stati di attesa possono essere utili quando si desidera ritardare l'esecuzione di ulteriori operazioni. Forse il flusso di lavoro aspetterà 30 secondi dopo l'immissione dell'ordine, in modo che il cliente abbia il tempo di notare e correggere un indirizzo di spedizione errato.

Gli stati paralleli possono eseguire più processi sui dati. Forse il flusso di lavoro stamperà un ticket d'ordine, aggiornerà l'inventario e aumenterà contemporaneamente un rapporto giornaliero sulle vendite.

Visualizza il codice del flusso di lavoro (ASL)

La tua prima macchina a stati è in effetti piuttosto dettagliata, quindi approfondisci esaminando il codice.

Le macchine a stati sono definite utilizzando Amazon States Language (ASL), una specifica open source che descrive un linguaggio basato su JSON per descrivere le macchine a stati in modo dichiarativo.

Per visualizzare l'intera definizione di macchina a stati

Hai notato come viene evidenziata la definizione dello stato nella vista del codice?

Per visualizzare il codice nell'Inspector

Provate a scegliere altri stati. Guarda come viene visualizzato ed evidenziato il codice ASL per ogni stato selezionato?

(In realtà) Crea la macchina a stati

Fino ad ora, hai lavorato su una bozza della tua macchina a stati. Nessuna risorsa è stata ancora creata.

Per rinominare e creare la tua macchina a stati

Dovresti vedere le notifiche che indicano che la tua macchina a stati e un nuovo ruolo IAM sono stati creati.

Ti verrà automaticamente presentata la possibilità di avviare la macchina a stati. Lo farai nel passaggio successivo!

Passaggio 2: avvia la tua macchina a stati

Dopo aver creato la macchina a stati, puoi avviare il flusso di lavoro.

I flussi di lavoro accettano facoltativamente input che possono essere utilizzati nello stato, inviati a servizi integrati e passati allo stato successivo.

La macchina a stati Hello World è autonoma e non necessita di input.

Per avviare la macchina a stati

Esamina i dettagli dell'esecuzione

Subito dopo l'avvio, dovresti vedere che i primi due stati hanno avuto successo.

Dopo una breve attesa, verranno eseguite le altre transizioni di stato per completare il flusso di lavoro.

Ti stai chiedendo come si trova lo stato di Choice (Is Hello World Example)? ) ha deciso di passare allo stato Wait for X Seconds?

Dovresti vedere che lo State input è vuoto, ma State output contiene JSON che imposta il valore di to. IsHelloWorldExample true

Passa dalla vista Grafico alla vista Tabella per visualizzare un elenco di stati per nome, tipo e stato.

In questa pagina dei dettagli delle esecuzioni sono disponibili altre due visualizzazioni da esplorare: visualizzazione degli eventi e visualizzazione dello stato.

La visualizzazione degli eventi è una visualizzazione dettagliata e granulare del flusso da uno stato all'altro.

Espandi la prima PassStateEnterede PassStateExitedgli eventi nella tabella Visualizzazione eventi per vedere come lo stato non riceve alcun input, assegna una variabile chiamata CheckpointCount valore zero e produce l'output visualizzato in precedenza.

Infine, hai la vista dello stato che è simile alla vista Tabella. Nella tabella di visualizzazione dello stato, puoi espandere selettivamente gli stati per visualizzare solo gli ingressi e le uscite per ogni stato:

Fase 3 - Elaborazione dell'input esterno

L'impostazione del valore di IsHelloWorldExample su un valore costante all'interno del flusso di lavoro non è realistica. Dovresti aspettarti che la tua macchina a stati risponda a dati di input diversi.

In questo passaggio, ti mostreremo come utilizzare i dati JSON esterni come input per il tuo flusso di lavoro:

Rimuovi l'input codificato

Innanzitutto, sostituisci il valore codificato nell'output dello stato del primo passaggio.

L'output dello stato aggiornato estrarrà i dati di input dalla variabile riservata $states utilizzando un' JSONata espressione. Questi valori verranno passati allo stato successivo come output per diventare l'input per lo stato successivo.

Esegui il flusso di lavoro aggiornato, con i dati di input

Quindi, esegui il flusso di lavoro e fornisci dati di input esterni come JSON.

L'esecuzione della macchina a stati dovrebbe attendere molto più a lungo (20 secondi), ma alla fine dovrebbe avere successo utilizzando l'input fornito.

Nella vista Grafico, esaminate l'input/output per il primo Pass State. Notate come l'input che avete fornito è stato convertito in output. Inoltre, dai un'occhiata all'input e all'output dell'esecuzione nella parte superiore della pagina dei dettagli dell'esecuzione. Entrambe le posizioni mostrano l'input che hai usato per avviare l'esecuzione.

Rivedi le esecuzioni del flusso di lavoro

Ora che hai eseguito il flusso di lavoro alcune volte, rivedi i dettagli di esecuzione per esaminare le esecuzioni del flusso di lavoro.

Per esaminare i dettagli dell'esecuzione

Nella scheda Esecuzioni, dovresti vedere un elenco di esecuzioni, simile alla seguente schermata:

Un'ultima nota: i nomi di esecuzione del flusso di lavoro devono essere univoci e non possono essere riutilizzati. Sebbene in questo tutorial abbiamo suggerito un nome breve (hello001), consigliamo di utilizzare una convenzione di denominazione che sarà sempre unica per i carichi di lavoro di produzione.

Fase 4 - Integrazione di un servizio

Le macchine a stati Step Functions possono richiamare oltre 220 AWS servizi utilizzando integrazioni AWS SDK. AWS i servizi forniscono oltre 10.000 potenziali azioni API per le vostre macchine a stati.

In questa fase, integrerai un task Amazon Comprehend per l'analisi del sentiment per elaborare l'input della tua macchina a stati.

Le integrazioni di servizi utilizzano uno dei tre modelli di integrazione dei servizi:

Per la prima integrazione, utilizzerai il modello di integrazione Request Response (predefinito).

Come funzionano le integrazioni?

Uno stato Task rappresenta una singola unità di lavoro eseguita da una macchina a stati. Tutte le operazioni nella macchina a stati vengono eseguite mediante task.

Un'attività in genere esegue il lavoro trasferendo input alle azioni API di altri servizi, che quindi eseguono il proprio lavoro. È possibile specificare il rendimento di un'attività utilizzando una serie di campi tra cui:Credentials,Retry, CatchTimeoutSeconds, e altro ancora. Puoi trovare ulteriori informazioni su Tasks inStato del flusso di lavoro delle attività.

Per utilizzare le integrazioni AWS SDK, devi specificare il nome del servizio e l'API da chiamare. Alcune integrazioni richiedono anche parametri.

Puoi utilizzare Amazon States Language per specificare un'azione AWS API nel campo Risorsa di uno stato dell'attività. Facoltativamente, puoi aggiungere un tipo di integrazione del servizio al nome del servizio.

Per specificare un'azione API, utilizzerai il seguente modello di nome della risorsa:

arn:aws:states:::aws-sdk:serviceName:apiAction.[serviceIntegrationPattern]

Esempi di nomi di risorse

Quando Step Functions chiama un altro servizio utilizzando lo Task stato, lo schema predefinito è Request Response. Con il pattern di integrazione Request Response, Step Functions chiama un servizio, riceve una risposta e passa immediatamente allo stato successivo.

Fase 4.1 - Aggiungere lo stato di analisi del sentimento

Fase 4.2 - Configurare lo stato di analisi del sentiment

Dopo aver scelto queste opzioni di completamento automatico, dovresti avere il seguente JSON per gli argomenti dei tuoi stati:

{
    "LanguageCode": "en",
    "Text": "{% $states.context.Execution.Input.feedback_comment %}"
}

Fase 4.3 - Configurare una politica di identità

Prima di poter eseguire il flusso di lavoro, è necessario creare un ruolo e una policy per consentire alla macchina a stati di eseguire chiamate API al servizio esterno.

Per creare un ruolo IAM per Step Functions

Per aggiungere una policy a HelloWorldWorkflowRoleper Amazon Comprehend

Per collegare un ruolo IAM alla macchina a stati Step Functions

Passaggio 4.4 - Esegui la tua macchina a stati

Inizia a eseguire la tua macchina a stati con il seguente codice JSON come input:

{
    "hello_world": false,
    "wait": 42,
    "feedback_comment" : "This getting started with Step Functions workshop is a challenge!"
}

User: arn:aws:sts::123456789012:assumed-role/StepFunctions-MyStateMachine-role is not authorized
to perform: comprehend:DetectSentiment because no identity-based policy allows the comprehend:DetectSentiment
action (Service: Comprehend, Status Code: 400, Request ID: a1b2c3d4-5678-90ab-cdef-EXAMPLE11111)
        

Metti in pratica ciò che hai imparato!

Prima di immergerti in flussi di lavoro più complessi, metti in pratica ciò che hai imparato con le seguenti attività:

Per ulteriori informazioni sui risultati dell'analisi del sentiment, consulta Amazon Comprehend - Sentiment.

Un modo di pensare all'integrazione con Request Response è che la risposta in genere rappresenta solo un riconoscimento della richiesta. Tuttavia, in alcune integrazioni, come l'analisi del sentiment, il riconoscimento rappresenta in realtà il completamento dell'attività.

L'apprendimento fondamentale è che Task lo stato non aspetta il job sottostante nelle integrazioni Request Response. Per attendere una risposta, dovrai esplorare il modello di integrazione del servizio Run a Job (.sync).

Pulizia delle risorse

Segui i passaggi seguenti per ripulire le risorse che hai creato:

La tua macchina a stati e il ruolo correlato dovrebbero ora essere eliminati con successo.