Elabora i dati da una coda con uno stato della mappa in Step Functions - AWS Step Functions

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Elabora i dati da una coda con uno stato della mappa in Step Functions

In questo flusso di lavoro di esempio, uno Stato del flusso di lavoro della mappa stato elabora i dati da una coda, invia messaggi ai sottoscrittori e li archivia in un database.

Step Functions utilizza un'integrazione ottimizzata per estrarre i messaggi da una SQS coda Amazon. Quando i messaggi sono disponibili, uno Choice stato passa una matrice di JSON messaggi a uno Eseguire la mappatura stato per l'elaborazione. Per ogni messaggio, la macchina a stati scrive il messaggio su DynamoDB, lo rimuove dalla coda e lo pubblica su un argomento Amazon. SNS

Questo progetto di esempio include le seguenti risorse:

  • Un record AWS Step Functions macchina a stati

  • Una SQS coda Amazon da cui lo stato della mappa legge e rimuove i messaggi in modo iterativo.

  • Una tabella DynamoDB in cui lo stato Map scrive i messaggi in modo iterativo.

  • Un SNS argomento Amazon su cui Step Functions pubblica i messaggi che legge dalla coda AmazonSQS.

  • Correlati AWS Identity and Access Management (IAM) ruoli

Fase 1: Creare la macchina a stati

  1. Apri la console Step Functions e scegli Crea macchina a stati.

  2. Trova e scegli Elabora dinamicamente i dati con uno stato della mappa. Seleziona Successivo per continuare.

  3. Scegli Esegui una demo per creare un ready-to-deploy flusso di lavoro di sola lettura o scegli Crea su di esso per creare una definizione di macchina a stati modificabile da utilizzare e distribuire in un secondo momento.

  4. Scegli Usa modello per continuare con la selezione.

I passaggi successivi dipendono dalla scelta precedente:

  1. Esegui una demo: puoi esaminare la macchina a stati prima di creare un progetto di sola lettura con risorse distribuite da AWS CloudFormation al tuo Account AWS.

    Puoi visualizzare la definizione della macchina a stati e, quando sei pronto, scegli Implementa ed esegui per distribuire il progetto e creare le risorse.

    La creazione di risorse e autorizzazioni può richiedere fino a 10 minuti per la distribuzione. Puoi utilizzare il link Stack ID per monitorare i progressi in AWS CloudFormation.

    Una volta completata la distribuzione, dovresti vedere la tua nuova macchina a stati nella console.

  2. Sviluppala: puoi rivedere e modificare la definizione del flusso di lavoro. Potrebbe essere necessario impostare i valori per i segnaposto nel progetto di esempio prima di provare a eseguire il flusso di lavoro personalizzato.

Nota

Potrebbero essere applicati costi standard per i servizi distribuiti sul tuo account.

Fase 2: Abbonarsi all'SNSargomento Amazon

Suggerimento

Iscriviti all'SNSargomento Amazon e aggiungi elementi alla SQS coda Amazon prima di avviare la tua macchina a stati.

  1. Apri la SNSconsole Amazon.

  2. Scegli Argomenti e trova l'argomento creato dal progetto di esempio.

  3. Scegli Crea abbonamento e, per Protocollo, scegli Email.

  4. In Endpoint, inserisci il tuo indirizzo email per iscriverti all'argomento.

  5. Scegli Crea sottoscrizione.

  6. Conferma l'iscrizione nella tua email per attivarla.

Passaggio 3: aggiungere messaggi alla SQS coda di Amazon

  1. Apri la SQSconsole Amazon.

  2. Scegli la coda creata dal progetto di esempio.

  3. Scegli Invia e ricevi messaggi, inserisci un messaggio e scegli Invia messaggio. Ripeti questo passaggio per aggiungere diversi messaggi alla coda.

Passaggio 4: Esegui la macchina a stati

Suggerimento

Le code in Amazon alla fine SNS sono coerenti. Potrebbe essere necessario attendere alcuni minuti dopo aver inviato i messaggi alla coda prima di avviare la macchina a stati.

  1. Nella pagina Macchine a stati, scegli il tuo progetto di esempio.

  2. Nella pagina del progetto di esempio, scegli Avvia esecuzione.

  3. Nella finestra di dialogo Avvia esecuzione, effettuate le seguenti operazioni:

    1. (Facoltativo) Immettete un nome di esecuzione personalizzato per sovrascrivere il valore predefinito generato.

      ASCIINomi diversi e registrazione

      Step Functions accetta nomi per macchine a stati, esecuzioni, attività ed etichette che contengono non ASCII caratteri. Poiché tali caratteri non funzioneranno con Amazon CloudWatch, ti consigliamo di utilizzare solo ASCII caratteri in modo da poter tenere traccia delle metriche. CloudWatch

    2. (Facoltativo) Nella casella Input, inserisci i valori di input comeJSON. Puoi saltare questo passaggio se stai eseguendo una demo.

    3. Selezionare Start execution (Avvia esecuzione).

    La console Step Functions ti indirizzerà a una pagina dei dettagli di esecuzione in cui puoi scegliere gli stati nella vista Graph per esplorare le informazioni correlate nel Dettagli del passaggio riquadro.

Complimenti!

Ora dovresti avere una demo in esecuzione o una definizione di macchina a stati che puoi personalizzare.