Verarbeiten Sie umfangreiche Nachrichten von Amazon SQS mit Step Functions Express-Workflows

Dieses Beispielprojekt zeigt, wie ein AWS Step Functions Express-Workflow verwendet wird, um Nachrichten oder Daten aus einer Ereignisquelle mit hohem Volumen wie Amazon Simple Queue Service (Amazon SQS) zu verarbeiten. Da Express-Workflows mit sehr hoher Rate gestartet werden können, eignen sie sich ideal für die Verarbeitung von hochvolumigen Ereignissen oder für Streamingdaten-Workloads.

Im Folgenden finden Sie zwei häufig verwendete Methoden für die Ausführung Ihres Zustandsautomaten über eine Ereignisquelle:

• Konfigurieren Sie eine Amazon CloudWatch Events-Regel, um eine State-Machine-Ausführung zu starten, wenn die Ereignisquelle ein Ereignis ausgibt. Weitere Informationen finden Sie unter Erstellen einer CloudWatch Ereignisregel, die bei einem Ereignis ausgelöst wird.

• Ordnen Sie die Ereignisquelle einer Lambda-Funktion zu und schreiben Sie Funktionscode zur Ausführung Ihres Zustandsautomaten. Die AWS Lambda Funktion wird jedes Mal aufgerufen, wenn Ihre Ereignisquelle ein Ereignis ausgibt, wodurch wiederum eine State-Machine-Ausführung gestartet wird. Weitere Informationen finden Sie unter AWS Lambda Mit Amazon SQS verwenden.

Dieses Beispielprojekt verwendet die zweite Methode, um jedes Mal eine Ausführung zu starten, wenn die Amazon SQS SQS-Warteschlange eine Nachricht sendet. Sie können eine ähnliche Konfiguration verwenden, um die Ausführung von Express Workflows aus anderen Ereignisquellen wie Amazon Simple Storage Service (Amazon S3), Amazon DynamoDB und Amazon Kinesis auszulösen.

Weitere Informationen zu Express Workflows- und Step Functions Functions-Dienstintegrationen finden Sie im Folgenden:

• Workflowtyp in Step Functions auswählen

• Integration von Diensten mit Step Functions

• Step Functions Servicequotas

Schritt 1: Erstellen Sie die Zustandsmaschine

1. Öffnen Sie die Step Functions Functions-Konsole und wählen Sie Create State Machine.

2. Wählen Sie Aus Vorlage erstellen und suchen Sie nach der entsprechenden Startvorlage. Wählen Sie Next (Weiter), um fortzufahren.

3. Wählen Sie aus, wie Sie die Vorlage verwenden möchten:

   1. Eine Demo ausführen — erstellt eine Zustandsmaschine mit Schreibschutz. Nach der Überprüfung können Sie den Workflow und alle zugehörigen Ressourcen erstellen.

   2. Darauf aufbauen — bietet eine bearbeitbare Workflow-Definition, die Sie mit Ihren eigenen Ressourcen überprüfen, anpassen und bereitstellen können. (Verwandte Ressourcen, wie Funktionen oder Warteschlangen, werden nicht automatisch erstellt.)

4. Wählen Sie Vorlage verwenden, um mit Ihrer Auswahl fortzufahren.

   Anmerkung

   Für Dienste, die für Ihr Konto bereitgestellt werden, fallen Standardgebühren an.

Schritt 2: Auslösen der State-Machine-Ausführung

1. Öffnen Sie die Amazon-SQS-Konsole.

2. Wählen Sie die Warteschlange aus, die vom Beispielprojekt erstellt wurde.

   Der Name wird Example- SQSQueue XUtn -WjALR FEMI ähneln.

3. Wählen Sie in der Liste Queue Actions (Warteschlangenaktionen) die Option Send a Message (Eine Nachricht senden) aus.

4. Verwenden Sie die Schaltfläche zum Kopieren, um die folgende Nachricht zu kopieren. Geben Sie sie dann im Fenster Send a Message (Eine Nachricht senden) ein und wählen Sie Send Message (Nachricht senden) aus.

   Anmerkung

   In dieser Beispielmeldung wurde die Zeile input: mit Zeilenumbrüchen formatiert, um sie an die Seite anzupassen. Verwenden Sie die Schaltfläche „Copy (Kopieren)“ oder stellen Sie anderweitig sicher, dass sie als einzelne Zeile ohne Umbrüche eingegeben wird.

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

5. Klicken Sie auf Close.

6. Öffnen Sie die Step Functions Functions-Konsole.

7. Gehen Sie zu Ihrer Amazon CloudWatch Logs-Protokollgruppe und überprüfen Sie die Protokolle. Der Name der Protokollgruppe wird wie Beispiel- ExpressLogGroup XUtn -WjALR FEMI aussehen.