Utilizzo di una funzione Lambda per continuare una nuova esecuzione in Step Functions

1. Aprire la console Lambda, quindi scegliere Create function (Crea funzione).

2. Nella pagina Create function (Crea funzione), scegliere Author from scratch (Crea da zero).

3. Nella sezione Informazioni di base, configura la tua funzione Lambda come segue:

   1. Nel campo Function name (Nome funzione), immettere Iterator.

   2. Per Runtime scegli Node.js 16.x.

   3. Mantieni tutte le selezioni predefinite sulla pagina, quindi scegli Crea funzione.

      Quando viene creata la funzione Lambda, prendi nota del relativo Amazon Resource Name (ARN) nell'angolo in alto a destra della pagina, ad esempio:

      arn:aws:lambda:us-east-1:123456789012:function:Iterator

4. Copiate il codice seguente per la funzione Lambda nella sezione Code source del Iteratorpagina nella console Lambda.

   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
     })
   }

   Questo codice ammette valori di input per count, index e step. Incrementa l'index del valore di step e restituisce tali valori e il valore booleano di continue. Il valore di continue è true se index è inferiore a count.

5. Scegli Deploy per distribuire il codice.

1. Nella finestra di dialogo Configure test event (Configura evento test), selezionare Create new test event (Crea nuovo evento test), per poi specificare TestIterator come Event name (Nome evento).

2. Sostituire i dati di esempio con quanto segue.

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

   Tali valori simulano quelli generati da una macchina a stati durante un'iterazione. La funzione Lambda incrementa l'indice e restituisce as. continue true Quando raggiunge un valore pari o superiore a count, l'indice restituisce continue come false. Per questo test, l'indice ha già subito un incremento a 5. I risultati dovrebbero annoverare l'incremento dell'index a 6 e l'impostazione di continue su true.

3. Scegli Create (Crea) .

4. Sul Iteratore nella tua console Lambda, assicurati che TestIteratorsia presente nell'elenco, quindi scegli Test.

   I risultati del test vengono visualizzati nella parte superiore della pagina. Selezionare Details (Dettagli) ed esaminare i risultati.

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

   Nota

   Un test eseguito con l'index impostato su 9 prevede l'incremento di tale index a 10 e l'impostazione di continue su false.

1. Aprire la console Lambda, quindi scegliere Create function (Crea funzione).

2. Nella pagina Create function (Crea funzione), scegliere Author from scratch (Crea da zero).

3. Nella sezione Informazioni di base, configura la tua funzione Lambda come segue:

   1. Nel campo Function name (Nome funzione), immettere Restart.

   2. Per Runtime scegli Node.js 16.x.

4. Mantieni tutte le selezioni predefinite sulla pagina, quindi scegli Crea funzione.

   Quando viene creata la funzione Lambda, prendi nota del relativo Amazon Resource Name (ARN) nell'angolo in alto a destra della pagina, ad esempio:

   arn:aws:lambda:us-east-1:123456789012:function:Iterator

5. Copiate il codice seguente per la funzione Lambda nella sezione Code source del Restartpagina nella console Lambda.

   Il codice seguente riduce il conteggio del numero di esecuzioni e avvia una nuova esecuzione della macchina a stati, includendo il valore ridotto.

   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. Scegli Deploy per distribuire il codice.

Per creare la macchina a stati

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

   Importante

   Assicurati che la tua macchina a stati utilizzi lo stesso AWS account e la stessa regione delle funzioni Lambda che hai creato in precedenza nei passaggi 1 e 2.

2. Nella finestra di dialogo Scegli un modello, seleziona Vuoto.

3. Scegliete Seleziona per aprire Workflow Studio inmodalità di progettazione.

4. In questo tutorial, scriverai la definizione Amazon States Language (ASL) della tua macchina a stati inEditor del codice. Per fare ciò, scegli Code.

5. Rimuovi il codice boilerplate esistente e incolla il codice seguente. Ricordati di sostituirle ARNs in questo codice con le ARNs funzioni Lambda che hai creato.

   {
       "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:us-east-1: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:us-east-1:123456789012:function:Restart",
             "Next": "Done"
           },
           "Done": {
               "Type": "Pass",
               "End": true 
           }
       }
   }

6. Specificate un nome per la vostra macchina a stati. Per fare ciò, scegli l'icona di modifica accanto al nome della macchina a stati predefinita di MyStateMachine. Quindi, nella configurazione della macchina a stati, specifica un nome nella casella Nome macchina a stati.

   Per questo tutorial, inserisci il nome ContinueAsNew.

7. (Facoltativo) Nella configurazione della macchina a stati, specificate altre impostazioni del flusso di lavoro, come il tipo di macchina a stati e il relativo ruolo di esecuzione.

   Per questo tutorial, mantieni tutte le selezioni predefinite nelle impostazioni della macchina a stati.

   Se in precedenza hai creato un IAM ruolo con le autorizzazioni corrette per la tua macchina a stati e desideri utilizzarlo, in Autorizzazioni seleziona Scegli un ruolo esistente, quindi seleziona un ruolo dall'elenco. Oppure seleziona Inserisci un ruolo ARN e quindi fornisci un ruolo ARN per quel IAM ruolo.

8. Nella finestra di dialogo Conferma creazione del ruolo, scegli Conferma per continuare.

   Puoi anche scegliere Visualizza le impostazioni del ruolo per tornare alla configurazione della macchina a stati.

   Nota

   Se elimini il IAM ruolo creato da Step Functions, Step Functions non può ricrearlo in un secondo momento. Allo stesso modo, se modifichi il ruolo (ad esempio, rimuovendo Step Functions dai principi della IAM politica), Step Functions non può ripristinare le impostazioni originali in un secondo momento.

9. Salva l'Amazon Resource Name (ARN) di questa macchina a stati in un file di testo. Dovrai fornire al ARN contempo l'autorizzazione alla funzione Lambda per avviare una nuova esecuzione di Step Functions.

1. Nella ContinueAsNewpagina, scegli Avvia esecuzione.

   Viene visualizzata la finestra di dialogo Avvia esecuzione.

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

   1. (Facoltativo) Inserite 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 funzionano con Amazon CloudWatch, ti consigliamo di utilizzare solo ASCII caratteri in modo da poter tenere traccia delle metriche. CloudWatch

   2. Nella casella Input, inserisci il seguente JSON input per eseguire il flusso di lavoro.

      {
        "restart": {
          "StateMachineArn": "arn:aws:states:us-east-1:123456789012:stateMachine:ContinueAsNew",
          "executionCount": 4
        }
      }
              

   3. Aggiorna il StateMachineArn campo con il ARN per la tua macchina a ContinueAsNew stati.

   4. Selezionare Start execution (Avvia esecuzione).

   5. La console Step Functions ti indirizza a una pagina intitolata con il tuo ID di esecuzione. Questa pagina è nota come pagina dei dettagli di esecuzione. In questa pagina è possibile esaminare i risultati dell'esecuzione man mano che l'esecuzione procede o dopo il suo completamento.

      Per esaminare i risultati dell'esecuzione, scegliete i singoli stati nella vista Grafico, quindi scegliete le singole schede Dettagli del passaggio nel riquadro per visualizzare i dettagli di ogni stato, inclusi rispettivamente input, output e definizione. Per i dettagli sulle informazioni sull'esecuzione che è possibile visualizzare nella pagina Dettagli di esecuzione, vederePanoramica dei dettagli di esecuzione.

      La vista Grafico mostra la prima delle quattro esecuzioni. Prima del completamento, passando per lo stato Restart verrà avviata una nuova esecuzione.

      

      Una volta completata questa esecuzione, puoi esaminare l'esecuzione successiva in esecuzione. Seleziona il ContinueAsNewlink in alto per visualizzare l'elenco delle esecuzioni. Dovresti vedere sia l'esecuzione chiusa di recente che l'esecuzione in corso avviata dalla funzione Restart Lambda.

      Una volta completate, tutte le quattro esecuzioni saranno visibili nell'elenco. L'esecuzione avviata per prima mostra il nome scelto dall'utente; le altre, invece, presentano un nome generato.