Verwenden einer Lambda-Funktion, um eine neue Ausführung in Step Functions fortzusetzen

1. Öffnen Sie die Lambda-Konsole und wählen Sie Create function (Funktion erstellen) aus.

2. Wählen Sie auf der Seite Create function die Option Author from scratch.

3. Konfigurieren Sie im Abschnitt Grundinformationen Ihre Lambda-Funktion wie folgt:

   1. Geben Sie für Function name (Funktionsname) Iterator ein.

   2. Wählen Sie für Runtime Node.js 16.x.

   3. Behalten Sie alle Standardauswahlen auf der Seite bei und wählen Sie dann Funktion erstellen.

      Nachdem Lambda Ihre Funktion erstellt hat, notieren Sie sich den Amazon-Ressourcennamen (ARN), zum Beispiel:

      arn:aws:lambda:region:123456789012:function:Iterator

4. Kopieren Sie den folgenden Code für die Lambda-Funktion in den Codequellbereich der Iterator Seite in der Lambda-Konsole.

   exports.handler = function iterator (event, context, callback) {
     let index = event.iterator.index;
     let step = event.iterator.step;
     let count = event.iterator.count;
    
     index = index + step;
    
     callback(null, {
       index,
       step,
       count,
       continue: index < count
     })
   }

   Dieser Code nimmt Eingabewerte für count, index und step entgegen. Er inkrementiert index um den Wert von step und gibt diese Werte sowie den Booleschen Wert continue zurück. Der Wert von continue ist true, wenn index kleiner als count ist.

5. Wählen Sie Deploy, um den Code bereitzustellen.

1. Wählen Sie im Dialogfeld Configure test event die Option Create new test event und geben Sie dann TestIterator für Event name ein.

2. Ersetzen Sie die Beispieldaten durch Folgendes.

   {
     "Comment": "Test my Iterator function",
     "iterator": {
       "count": 10,
       "index": 5,
       "step": 1
     }
   }
   

   Diese Werte ahmen nach, was während einer Iteration aus Ihrem Zustandsautomaten kommt. Die Lambda-Funktion erhöht den Index und gibt als zurück. continue true Wenn der Index nicht geringer ist als count, wird continue als false zurückgegeben. Für diesen Test wurde der Index bereits auf 5 inkrementiert. Die Ergebnisse sollten index auf 6 inkrementieren und continue auf true setzen.

3. Wählen Sie Erstellen aus.

4. Vergewissern Sie sich, dass auf der Iterator Seite in Ihrer Lambda-Konsole die Liste aufgeführt TestIterator ist, und wählen Sie dann Test aus.

   Die Testergebnisse werden auf der Seite angezeigt. Wählen Sie Details und sehen Sie sich das Ergebnis an.

   {
     "index": 6,
     "step": 1,
     "count": 10,
     "continue": true
   }
   

   Anmerkung

   Wenn Sie index für diesen Test auf 9 setzen, wird index auf 10 inkrementiert und continue ist false.

1. Öffnen Sie die Lambda-Konsole und wählen Sie Create function (Funktion erstellen) aus.

2. Wählen Sie auf der Seite Create function die Option Author from scratch.

3. Konfigurieren Sie im Abschnitt Grundinformationen Ihre Lambda-Funktion wie folgt:

   1. Geben Sie für Function name (Funktionsname) Restart ein.

   2. Wählen Sie für Runtime Node.js 16.x.

4. Behalten Sie alle Standardauswahlen auf der Seite bei und wählen Sie dann Funktion erstellen.

   Nachdem Lambda Ihre Funktion erstellt hat, notieren Sie sich den Amazon-Ressourcennamen (ARN), zum Beispiel:

   arn:aws:lambda:region:123456789012:function:Iterator

5. Kopieren Sie den folgenden Code für die Lambda-Funktion in den Codequellbereich der Restart Seite in der Lambda-Konsole.

   Der folgende Code dekrementiert einen Zähler für die Ausführungsanzahl und startet eine neue Ausführung Ihres Zustandsautomaten, einschließlich des dekrementierten Wertes.

   var aws = require('aws-sdk');
   var sfn = new aws.StepFunctions();
   
   exports.restart = function(event, context, callback) {
   
     let StateMachineArn = event.restart.StateMachineArn;
     event.restart.executionCount -= 1;
     event = JSON.stringify(event);
   
     let params = {
         input: event,
         stateMachineArn: StateMachineArn
     };
   
     sfn.startExecution(params, function(err, data) {
         if (err) callback(err);
         else callback(null,event);
     });
   
   }

6. Wählen Sie Deploy, um den Code bereitzustellen.

So erstellen Sie den -Zustandsautomaten

1. Öffnen Sie die Step Functions-Konsole, wählen Sie im Menü die Option State Machines und anschließend Create State Machine aus.

   Wichtig

   Stellen Sie sicher, dass sich Ihr State Machine unter demselben AWS Konto und derselben Region befindet wie die Lambda-Funktionen, die Sie zuvor in Schritt 1 und Schritt 2 erstellt haben.

2. Wählen Sie Aus leerem Feld erstellen aus.

3. Benennen Sie Ihren Zustandsmaschinen und wählen Sie dann Weiter, um Ihren Zustandsmaschine in Workflow Studio zu bearbeiten.

4. Für dieses Tutorial schreiben Sie die Sprache der Amazonas-Staaten (ASL) -Definition Ihres Zustandsautomaten in denCode-Editor. Wählen Sie dazu Code.

5. Entfernen Sie den vorhandenen Boilerplate-Code und fügen Sie den folgenden Code ein. Denken Sie daran, die ARNs in diesem Code durch die ARNs der von Ihnen erstellten Lambda-Funktionen zu ersetzen.

   {
       "Comment": "Continue-as-new State Machine Example",
       "StartAt": "ConfigureCount",
       "States": {
           "ConfigureCount": {
               "Type": "Pass",
               "Result": {
                   "count": 100,
                   "index": -1,
                   "step": 1
               },
               "ResultPath": "$.iterator",
               "Next": "Iterator"
           },
           "Iterator": {
               "Type": "Task",
               "Resource": "arn:aws:lambda:region:123456789012:function:Iterator",
               "ResultPath": "$.iterator",
               "Next": "IsCountReached"
           },
           "IsCountReached": {
               "Type": "Choice",
               "Choices": [
                   {
                       "Variable": "$.iterator.continue",
                       "BooleanEquals": true,
                       "Next": "ExampleWork"
                   }
               ],
               "Default": "ShouldRestart"
           },
           "ExampleWork": {
               "Comment": "Your application logic, to run a specific number of times",
               "Type": "Pass",
               "Result": {
                 "success": true
               },
               "ResultPath": "$.result",
               "Next": "Iterator"
           },
           "ShouldRestart": {
             "Type": "Choice",
             "Choices": [
               {
                 "Variable": "$.restart.executionCount",
                 "NumericGreaterThan": 0,
                 "Next": "Restart"
               }
             ],
             "Default": "Done"
           },
           "Restart": {
             "Type": "Task",
             "Resource": "arn:aws:lambda:region:123456789012:function:Restart",
             "Next": "Done"
           },
           "Done": {
               "Type": "Pass",
               "End": true 
           }
       }
   }

6. Geben Sie einen Namen für Ihre Zustandsmaschine an. Wählen Sie dazu das Bearbeitungssymbol neben dem Standard-State-Machine-Namen von MyStateMachine. Geben Sie dann unter State Machine Configuration einen Namen in das Feld State Machine Name ein.

   Geben Sie für dieses Tutorial den Namen ContinueAsNew ein.

7. (Optional) Geben Sie unter Zustandsmaschinenkonfiguration weitere Workflow-Einstellungen an, z. B. den Zustandsautomatentyp und die zugehörige Ausführungsrolle.

   Behalten Sie für dieses Tutorial alle Standardauswahlen in den State-Machine-Einstellungen bei.

   Wenn Sie zuvor eine IAM-Rolle mit den richtigen Berechtigungen für Ihren State Machine erstellt haben und diese verwenden möchten, wählen Sie unter Berechtigungen die Option Vorhandene Rolle auswählen aus , und wählen Sie dann eine Rolle aus der Liste aus. Oder wählen Sie Geben Sie einen Rollen-ARN ein und geben Sie dann einen ARN für diese IAM-Rolle ein.

8. Wählen Sie im Dialogfeld „Rollenerstellung bestätigen“ die Option „Bestätigen“, um fortzufahren.

   Sie können auch Rolleneinstellungen anzeigen wählen, um zur State-Machine-Konfiguration zurückzukehren.

   Anmerkung

   Wenn Sie die von Step Functions erstellte IAM-Rolle löschen, kann Step Functions sie später nicht erneut erstellen. Ebenso kann Step Functions die ursprünglichen Einstellungen später nicht wiederherstellen, wenn Sie die Rolle ändern (z. B. indem Sie Step Functions aus den Principals in der IAM-Richtlinie entfernen).

9. Speichern Sie den Amazon-Ressourcennamen (ARN) dieses Zustandsmaschinen in einer Textdatei. Sie müssen den ARN angeben und gleichzeitig der Lambda-Funktion die Erlaubnis erteilen, eine neue Step Functions-Ausführung zu starten.

1. Wählen Sie auf der ContinueAsNew Seite Ausführung starten aus.

   Das Dialogfeld Ausführung starten wird angezeigt.

2. Gehen Sie im Dialogfeld Ausführung starten wie folgt vor:

   1. (Optional) Geben Sie einen benutzerdefinierten Ausführungsnamen ein, um den generierten Standard zu überschreiben.

      Non-ASCII Namen und Protokollierung

      Step Functions akzeptiert Namen für Zustandsautomaten, Ausführungen, Aktivitäten und Bezeichnungen, die Nicht-ASCII-Zeichen enthalten. Da solche Zeichen verhindern, dass Amazon Daten protokolliert, empfehlen wir, nur ASCII-Zeichen zu verwenden, damit Sie die Metriken CloudWatch von Step Functions verfolgen können.

   2. Geben Sie im Eingabefeld die folgende JSON-Eingabe ein, um Ihren Workflow auszuführen.

      {
        "restart": {
          "StateMachineArn": "arn:aws:states:region:account-id:stateMachine:ContinueAsNew",
          "executionCount": 4
        }
      }
              

   3. Aktualisieren Sie das Feld StateMachineArn mit dem ARN für den Zustandsautomaten ContinueAsNew.

   4. Wählen Sie Start execution (Ausführung starten) aus.

   5. Die Step Functions-Konsole leitet Sie zu einer Seite weiter, die mit Ihrer Ausführungs-ID betitelt ist. Diese Seite wird als Seite mit den Ausführungsdetails bezeichnet. Auf dieser Seite können Sie die Ausführungsergebnisse überprüfen, während die Ausführung voranschreitet oder nachdem sie abgeschlossen ist.

      Um die Ausführungsergebnisse zu überprüfen, wählen Sie in der Diagrammansicht einzelne Bundesstaaten aus. Wählen Sie dann die einzelnen Registerkarten im Einzelheiten zu den Schritten Bereich aus, um die Details der einzelnen Bundesstaaten einschließlich Eingabe, Ausgabe und Definition anzuzeigen. Einzelheiten zu den Ausführungsinformationen, die Sie auf der Seite mit den Ausführungsdetails einsehen können, finden Sie unterÜberblick über die Ausführungsdetails.

      In der Diagrammansicht wird die erste der vier Ausführungen angezeigt. Bevor sie abgeschlossen ist, durchläuft sie den Restart-Zustand und startet eine neue Ausführung.

      

      Wenn diese Ausführung abgeschlossen ist, können Sie sich die nächste Ausführung ansehen, die gerade ausgeführt wird. Wählen Sie den ContinueAsNew Link oben, um die Liste der Ausführungen anzuzeigen. Sie sollten sowohl die kürzlich abgeschlossene Ausführung als auch eine laufende Ausführung sehen, die von der Restart Lambda-Funktion gestartet wurde.

      Wenn alle Ausführungen abgeschlossen sind, sollten Sie vier erfolgreiche Ausführungen in der Liste sehen. Die erste gestartete Ausführung zeigt den von Ihnen gewählten Namen. Nachfolgende Ausführungen haben einen generierten Namen.