Elabora messaggi ad alto volume da Amazon SQS con flussi di lavoro Step Functions Express

Questo progetto di esempio dimostra come utilizzare un AWS Step Functions Express Workflow per elaborare messaggi o dati da una fonte di eventi ad alto volume, come Amazon Simple Queue Service (Amazon SQS). Dal momento che i flussi di lavoro Express possono essere avviati a una velocità molto elevata, sono ideali per i carichi di lavoro di elaborazione eventi o di streaming dei dati a volume elevato.

Di seguito sono indicati due metodi utilizzati comunemente per eseguire la macchina a stati da un'origine evento:

• Configura una regola Amazon CloudWatch Events per avviare l'esecuzione di una macchina a stati ogni volta che l'origine dell'evento emette un evento. Per ulteriori informazioni, consulta Creazione di una regola per CloudWatch gli eventi che si attiva su un evento.

• Mappare l'origine evento a una funzione Lambda e scrivere codice di funzione per eseguire la macchina a stati. La AWS Lambda funzione viene richiamata ogni volta che l'origine dell'evento emette un evento, avviando a sua volta l'esecuzione di una macchina a stati. Per ulteriori informazioni, consulta Using AWS Lambda with Amazon SQS.

Questo progetto di esempio utilizza il secondo metodo per avviare un'esecuzione ogni volta che la coda Amazon SQS invia un messaggio. Puoi utilizzare una configurazione simile per attivare l'esecuzione di Express Workflows da altre fonti di eventi, come Amazon Simple Storage Service (Amazon S3), Amazon DynamoDB e Amazon Kinesis.

Per ulteriori informazioni sulle integrazioni dei servizi Express Workflows e Step Functions, consulta quanto segue:

• Scelta del tipo di flusso di lavoro in Step Functions

• Integrazione dei servizi con Step Functions

• Quote di servizio Step Functions

Fase 1: Creare la macchina a stati

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

2. Scegli Crea da modello e trova il modello iniziale correlato. Seleziona Successivo per continuare.

3. Scegli come usare il modello:

   1. Esegui una demo: crea una macchina a stati di sola lettura. Dopo la revisione, puoi creare il flusso di lavoro e tutte le risorse correlate.

   2. Basati su di esso: fornisce una definizione modificabile del flusso di lavoro che puoi rivedere, personalizzare e implementare con le tue risorse. (Le risorse correlate, come funzioni o code, non verranno create automaticamente.)

4. Scegli Usa modello per continuare con la selezione.

   Nota

   Per i servizi distribuiti sul tuo account si applicano le tariffe standard.

Fase 2: Attivare l'esecuzione della macchina a stati

1. Apri la console Amazon SQS.

2. Selezionare la coda creata dal progetto di esempio.

   Il nome sarà simile a Example- SQSQueue XUtn -WJAlr FEMI.

3. Dall'elenco Queue Actions (Azioni coda), selezionare Send a Message (Invia un messaggio).

4. Utilizzare il pulsante di copia per copiare il seguente messaggio, quindi immetterlo nella finestra Send a Message (Invia un messaggio) e scegliere Send Message (Invia messaggio).

   Nota

   In questo messaggio di esempio sono state inserite interruzioni di riga nella riga input: per adattarla alla pagina. Utilizzare il pulsante di copia o assicurarsi in altro modo che venga immesso come singola riga senza interruzioni.

   {
         "input": "QW5kIGxpa2UgdGhlIGJhc2VsZXNzIGZhYnJpYyBvZiB0aGlzIHZpc2lvbiwgVGhlIGNsb3VkLWNhcHBlZCB0b3dlcnMsIHRoZSBnb3JnZW
                   91cyBwYWxhY2VzLCBUaGUgc29sZW1uIHRlbXBsZXMsIHRoZSBncmVhdCBnbG9iZSBpdHNlbGbigJQgWWVhLCBhbGwgd2hpY2ggaXQgaW5o
                   ZXJpdOKAlHNoYWxsIGRpc3NvbHZlLCBBbmQgbGlrZSB0aGlzIGluc3Vic3RhbnRpYWwgcGFnZWFudCBmYWRlZCwgTGVhdmUgbm90IGEgcm
                   FjayBiZWhpbmQuIFdlIGFyZSBzdWNoIHN0dWZmIEFzIGRyZWFtcyBhcmUgbWFkZSBvbiwgYW5kIG91ciBsaXR0bGUgbGlmZSBJcyByb3Vu
                   ZGVkIHdpdGggYSBzbGVlcC4gU2lyLCBJIGFtIHZleGVkLiBCZWFyIHdpdGggbXkgd2Vha25lc3MuIE15IG9sZCBicmFpbiBpcyB0cm91Ym
                   xlZC4gQmUgbm90IGRpc3R1cmJlZCB3aXRoIG15IGluZmlybWl0eS4gSWYgeW91IGJlIHBsZWFzZWQsIHJldGlyZSBpbnRvIG15IGNlbGwg
                   QW5kIHRoZXJlIHJlcG9zZS4gQSB0dXJuIG9yIHR3byBJ4oCZbGwgd2FsayBUbyBzdGlsbCBteSBiZWF0aW5nIG1pbmQu"
   }

5. Scegli Chiudi.

6. Apri la console Step Functions.

7. Vai al tuo gruppo di CloudWatch log Amazon Logs e ispeziona i log. Il nome del gruppo di log sarà simile a example- ExpressLogGroup -WJAlr FEMI. XUtn