Erfahren Sie, wie Sie mit Step Functions beginnen

Mit dem Step Functions Functions-Dienst können Sie komplexe Anwendungsworkflows orchestrieren. Zu Beginn verwenden Sie Workflow Studio, um einen integrierten Hello World-Workflow zu erstellen und auszuführen. Sie werden die automatisch generierte Amazon States Language (ASL) Definition im Code überprüfen. Schließlich erhalten Sie drag-and-drop eine Serviceintegration zur Stimmungsanalyse.

Nachdem Sie dieses Tutorial abgeschlossen haben, wissen Sie, wie Sie Workflow Studio verwenden, um einen Workflow sowohl im Entwurfs - als auch im Codemodus zu erstellen, zu konfigurieren, auszuführen und zu aktualisieren.

Geschätzte Dauer: 20-30 Minuten

Was du bauen wirst

Ihre erste Zustandsmaschine beginnt mit Flow-Zuständen. Flow-Status werden verwendet, um Ihren Arbeitsablauf zu steuern und zu steuern. Nachdem Sie gelernt haben, wie der Workflow ausgeführt wird, fügen Sie eine Aktion hinzu, um den Amazon Comprehend-Service in einen Task-Status zu integrieren.

Das folgende Diagramm zeigt eine visuelle Darstellung der kompletten Zustandsmaschine, die Sie erstellen werden. Wenn Sie den Hello World State Machine zum ersten Mal erstellen, benötigt er keine zusätzlichen Ressourcen, um ausgeführt zu werden. Die Step Functions Functions-Konsole erstellt alle Status und eine IAM Rolle mit einem einzigen Klick. Später, wenn Sie die Serviceintegration hinzufügen, müssen Sie eine Rolle mit einer benutzerdefinierten Berechtigungsrichtlinie erstellen.

Schritt 1 — Erstellen Sie Ihre Zustandsmaschine

In Step Functions werden Workflows als Zustandsmaschinen bezeichnet. Wir werden beide Begriffe synonym verwenden. Ihre Workflows werden Staaten enthalten, die entweder Maßnahmen ergreifen oder den Ablauf Ihrer Zustandsmaschinen steuern.

Überblick über Workflow Studio

Mit Workflow Studio for Step Functions können Sie drag-and-drop Zustände visuell auf einer Arbeitsfläche anzeigen, um Workflows zu erstellen.

Sie können Status hinzufügen und bearbeiten, Schritte konfigurieren, Ergebnisse transformieren und die Fehlerbehandlung einrichten. Der folgende Screenshot zeigt vier wichtige Bereiche der Benutzeroberfläche, die Sie zum Erstellen Ihrer Zustandsmaschinen verwenden werden.

Modi — Workflow Studio bietet drei Betriebsmodi und ist standardmäßig auf den visuellen Designmodus eingestellt.

Der States-Browser enthält die folgenden drei Registerkarten:

In der Arbeitsfläche und im Workflow-Diagramm wechseln Sie drag-and-drop zu Ihrem Workflow-Diagramm, ändern die Reihenfolge der Zustände und wählen die Status aus, die konfiguriert und getestet werden sollen.

Im Inspektorfenster können Sie die Eigenschaften jedes auf der Leinwand ausgewählten Status anzeigen und bearbeiten. Sie können den Schalter Definition aktivieren, um den Code für den aktuell ausgewählten Status anzuzeigen.

Überblick über die Zustandsmaschine

Der Hello World-Workflow beginnt mit einem Pass-Status, der seine Eingabe an seine Ausgabe weitergibt, ohne Arbeit auszuführen. Pass-Status können verwendet werden, um statische JSON Ausgaben zu generieren oder JSON Eingaben zu transformieren, bevor die Daten an den nächsten Status übergeben werden. Pass-Status sind nützlich beim Konstruieren und Debuggen von Zustandsmaschinen.

Der nächste Status, ein Choice-Status, verwendet die Daten, IsHelloWorldExample um den nächsten Zweig des Workflows auszuwählen. Wenn die erste Regel zutrifft, pausiert der Workflow im Status Warten und führt dann zwei Aufgaben im Status Parallel aus, bevor er zu einem Checkpoint übergeht und der Workflow erfolgreich beendet wird. Wenn es keine Übereinstimmung gibt, nimmt der Workflow standardmäßig den Status Fehlgeschlagen an, bevor der Zustandsmaschine angehalten wird.

Wartestatus kann nützlich sein, wenn Sie warten möchten, bevor Sie weitere Arbeiten ausführen. Möglicherweise wartet Ihr Workflow nach einer Auftragseingabe 30 Sekunden, sodass Ihr Kunde Zeit hat, eine falsche Lieferadresse zu bemerken und zu korrigieren.

Parallele Zustände können mehrere Prozesse auf Ihren Daten ausführen. Möglicherweise druckt der Workflow gleichzeitig ein Bestellticket, aktualisiert das Inventar und erstellt einen täglichen Verkaufsbericht.

Sehen Sie sich den Workflow-Code an () ASL

Ihr erster Zustandsmaschine ist in der Tat ziemlich detailliert. Gehen Sie also näher darauf ein, indem Sie sich den Code ansehen.

Zustandsmaschinen werden mithilfe von Amazon States Language (ASL) definiert, einer Open-Source-Spezifikation, die eine JSON basierte Sprache zur deklarativen Beschreibung von Zustandsmaschinen beschreibt.

Um die gesamte Zustandsmaschinen-Definition anzuzeigen

Ist Ihnen aufgefallen, wie die Definition des Bundesstaates in der Codeansicht hervorgehoben ist?

Um Code im Inspector anzuzeigen

Versuchen Sie, andere Bundesstaaten auszuwählen. Siehst du, wie der ASL Code für jeden Bundesstaat, den du auswählst, in die Ansicht gescrollt und hervorgehoben wird?

(Eigentlich) Erstellen Sie die Zustandsmaschine

Bis jetzt haben Sie an einem Entwurf Ihres State Machine gearbeitet. Es wurden noch keine Ressourcen erstellt.

Um Ihre Zustandsmaschine umzubenennen und zu erstellen

Sie sollten Benachrichtigungen darüber erhalten, dass Ihr Zustandsmaschine und eine neue IAM Rolle erstellt wurden.

Sie erhalten automatisch die Option, die Zustandsmaschine zu starten. Das wirst du im nächsten Schritt tun!

Schritt 2 — Starten Sie Ihren State Machine

Nachdem Ihr State Machine erstellt wurde, können Sie mit der Ausführung Ihres Workflows beginnen.

Workflows akzeptieren optional Eingaben, die im Status verwendet, an integrierte Dienste gesendet und an den nächsten Status übergeben werden können.

Die Hello World-Zustandsmaschine ist eigenständig und benötigt keine Eingabe.

Um die Zustandsmaschine zu starten

Überprüfen Sie die Ausführungsdetails

Unmittelbar nach dem Start sollten Sie sehen, dass die ersten beiden Status erfolgreich waren.

Nach einer kurzen Wartezeit werden die restlichen Statusübergänge ausgeführt, um den Workflow abzuschließen.

Fragst du dich, wie der Status Choice aussieht (ist Hello World Beispiel)? ) hat beschlossen, in den Status Wait for X Seconds zu wechseln?

Sie sollten sehen, dass die State-Eingabe leer ist, die State-Ausgabe jedoch enthältJSON, die den Wert auf festlegt. IsHelloWorldExample true

Wechseln Sie von der Diagrammansicht zur Tabellenansicht, um eine Liste der Bundesstaaten nach Name, Typ und Status anzuzeigen.

Auf dieser Seite mit den Ausführungsdetails gibt es zwei weitere Ansichten zu entdecken: die Ereignisansicht und die Statusansicht.

Die Ereignisansicht ist eine detaillierte detaillierte Ansicht des Datenflusses von Status zu Status.

Erweitern Sie das erste PassStateEnteredund die PassStateExitedEreignisse in der Tabelle „Ereignisansicht“, um zu sehen, wie der Status keine Eingaben akzeptiert, eine Variable mit CheckpointCount dem Wert Null zuweist und die Ausgabe erzeugt, die Sie zuvor gesehen haben.

Schließlich haben Sie die Statusansicht, die der Tabellenansicht ähnelt. In der Tabelle mit der Statusansicht können Sie Status selektiv erweitern, sodass nur die Eingaben und Ausgaben für jeden Status angezeigt werden:

Schritt 3 — Verarbeiten Sie externe Eingaben

Es ist nicht realistischIsHelloWorldExample, den Wert von innerhalb des Workflows auf einen konstanten Wert festzulegen. Sie sollten davon ausgehen, dass Ihre Zustandsmaschine auf unterschiedliche Eingabedaten reagiert.

In diesem Schritt zeigen wir Ihnen, wie externe JSON Daten als Eingabe für Ihren Workflow verwendet werden können:

Entfernen Sie die hartcodierte Eingabe

Ersetzen Sie zunächst den hartcodierten Wert im Status „Ausgabe des ersten Durchlaufs“.

Die aktualisierte Statusausgabe ruft mithilfe eines JSONata Ausdrucks Eingabedaten aus der reservierten Variablen $states ab. Diese Werte werden als Ausgabe an den nächsten Status übergeben und dienen als Eingabe für den nächsten Status.

Führen Sie den aktualisierten Workflow mit den Eingabedaten aus

Führen Sie als Nächstes den Workflow aus und geben Sie externe Eingabedaten als anJSON.

Die Ausführung Ihrer Zustandsmaschine sollte viel länger warten (20 Sekunden), aber irgendwann sollte sie mit der von Ihnen eingegebenen Eingabe erfolgreich sein.

Überprüfen Sie in der Diagrammansicht die Eingabe/Ausgabe für den Status „First Pass“. Beachten Sie, wie die von Ihnen eingegebene Eingabe in Ausgaben umgewandelt wurde. Sehen Sie sich auch die Eingabe und Ausgabe der Ausführung oben auf der Seite mit den Ausführungsdetails an. An beiden Stellen wird die Eingabe angezeigt, mit der Sie die Ausführung gestartet haben.

Überprüfen Sie die Workflow-Ausführungen

Nachdem Sie Ihren Workflow nun einige Male ausgeführt haben, überprüfen Sie die Ausführungsdetails, um die Ausführungen Ihres Workflows zu überprüfen.

Um die Ausführungsdetails zu überprüfen

Auf der Registerkarte Ausführungen sollte eine Liste von Ausführungen angezeigt werden, die dem folgenden Screenshot ähnelt:

Ein letzter Hinweis: Die Namen der Workflow-Ausführung müssen eindeutig sein und können nicht wiederverwendet werden. Obwohl wir in diesem Tutorial einen Kurznamen (hello001) vorgeschlagen haben, empfehlen wir, eine Benennungskonvention zu verwenden, die für Ihre Produktionsworkloads immer eindeutig ist.

Schritt 4 — Integrieren Sie einen Service

Step Functions Functions-Zustandsmaschinen können mithilfe von AWS SDKIntegrationen über 220 AWS Dienste aufrufen. AWS Dienste bieten über 10.000 potenzielle API Aktionen für Ihre Zustandsmaschinen.

In diesem Schritt integrieren Sie eine Amazon Comprehend Comprehend-Aufgabe zur Stimmungsanalyse, um Ihre State-Machine-Eingaben zu verarbeiten.

Serviceintegrationen verwenden eines von drei Serviceintegrationsmustern:

Für Ihre erste Integration verwenden Sie das Integrationsmuster Request Response (Standard).

Wie funktionieren Integrationen?

Ein Task-Status steht für eine einzelne Arbeitseinheit, die von einer Zustandsmaschine ausgeführt wird. Die gesamte Arbeit in Ihrer Zustandsmaschine wird durch Aufgaben durchgeführt.

Eine Aufgabe führt in der Regel Arbeit aus, indem sie Eingaben an die API Aktionen anderer Dienste weitergibt, die dann ihre eigene Arbeit ausführen. Sie können angeben, wie eine Aufgabe ausgeführt wird, indem Sie eine Reihe von Feldern verwendenCredentials, darunter: RetryCatch,TimeoutSeconds,, und mehr. Weitere Informationen zu Aufgaben finden Sie unterWorkflow-Status der Aufgabe.

Um AWS SDK Integrationen zu verwenden, geben Sie den Namen des Dienstes und den Aufruf APIan. Für einige Integrationen sind auch Parameter erforderlich.

Sie können Amazon States Language verwenden, um eine AWS API Aktion im Feld Ressource eines Aufgabenstatus anzugeben. Sie können dem Servicenamen optional einen Service-Integrationstyp hinzufügen.

Um eine API Aktion anzugeben, verwenden Sie die folgende Vorlage für einen Ressourcennamen:

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

Beispiele für Ressourcennamen

Wenn Step Functions einen anderen Dienst unter Verwendung des Task Status aufruft, ist das Standardmuster Request Response. Mit dem Request Response-Integrationsmuster ruft Step Functions einen Dienst auf, empfängt eine Antwort und wechselt sofort zum nächsten Status.

Schritt 4.1 — Status der Stimmungsanalyse hinzufügen

Schritt 4.2 — Konfigurieren Sie den Status der Stimmungsanalyse

Nachdem Sie diese Optionen für die automatische Vervollständigung ausgewählt haben, sollten Sie die folgenden Argumente JSON für Ihre Bundesstaaten haben:

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

Schritt 4.3 — Konfigurieren Sie eine Identitätsrichtlinie

Bevor Sie den Workflow ausführen können, müssen Sie eine Rolle und eine Richtlinie erstellen, damit der Zustandsmaschine API Aufrufe an den externen Dienst ausführen kann.

So erstellen Sie eine IAM Rolle für Step Functions

So fügen Sie dem HelloWorldWorkflowRolefür Amazon Comprehend eine Richtlinie hinzu

Um die IAM Rolle an die Step Functions Functions-Zustandsmaschine anzuhängen

Schritt 4.4 — Führen Sie Ihren State Machine aus

Starten Sie die Ausführung Ihrer Zustandsmaschine mit JSON den folgenden Eingaben:

{
    "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)
        

Übe, was du gelernt hast!

Bevor Sie sich mit komplexeren Arbeitsabläufen befassen, üben Sie das Gelernte anhand der folgenden Aufgaben:

Weitere Informationen zu den Ergebnissen der Stimmungsanalyse finden Sie unter Amazon Comprehend — Sentiment.

Eine Möglichkeit, über die Integration von Request Response nachzudenken, ist, dass die Antwort im Allgemeinen nur eine Bestätigung der Anfrage darstellt. Bei einigen Integrationen, wie z. B. der Stimmungsanalyse, stellt die Bestätigung jedoch tatsächlich den Abschluss der Aufgabe dar.

Die wichtigste Erkenntnis besteht darin, dass der Task Staat nicht auf die zugrundeliegende Aufgabe wartet, wenn es um Request-Response-Integrationen geht. Um auf eine Antwort zu warten, müssen Sie das Dienstintegrationsmuster Run a Job (.sync) untersuchen.

Bereinigen von -Ressourcen

Gehen Sie wie folgt vor, um die von Ihnen erstellten Ressourcen zu bereinigen:

Ihr Zustandsmaschine und die zugehörige Rolle sollten jetzt erfolgreich gelöscht werden.