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 nella pagina, quindi scegli la funzione Crea.

      Dopo che Lambda ha creato la tua funzione, prendi nota del suo Amazon Resource Name (ARN), ad esempio:

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

4. Copia il codice seguente per la funzione Lambda nella sezione Code source della Iterator pagina 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. Nella Iterator pagina della tua console Lambda, assicurati che TestIterator sia elencato, quindi scegli Test.

   I risultati del test vengono visualizzati nella 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 nella pagina, quindi scegli la funzione Crea.

   Dopo che Lambda ha creato la tua funzione, prendi nota del suo Amazon Resource Name (ARN), ad esempio:

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

5. Copia il codice seguente per la funzione Lambda nella sezione Code source della Restart pagina 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, scegli State machines dal menu, quindi scegli Create state machine.

   Importante

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

2. Scegli Crea da vuoto.

3. Assegna un nome alla tua macchina a stati, quindi scegli Continua per modificare la tua macchina a stati in Workflow Studio.

4. Per questo tutorial, scriverai la definizione Lingua degli Stati di Amazon (ASL) della tua macchina a stati in. Editor del codice Per fare ciò, scegli Codice.

5. Rimuovi il codice standard esistente e incolla il codice seguente. Ricorda di sostituire gli ARN in questo codice con gli ARN delle 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: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. Specifica un nome per la tua 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, specificate un nome nella casella Nome macchina a stato.

   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 stato.

   Se in precedenza hai creato un ruolo IAM 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 ARN per il ruolo e quindi fornisci un ARN per quel ruolo IAM.

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

   Puoi anche scegliere Visualizza le impostazioni dei ruoli per tornare alla configurazione della macchina State.

   Nota

   Se elimini il ruolo IAM creato da Step Functions, Step Functions non può ricrearlo in un secondo momento. Analogamente, se modifichi il ruolo (ad esempio, rimuovendo Step Functions dai principali nella policy IAM), 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 l'ARN mentre fornisci l'autorizzazione alla funzione Lambda per avviare una nuova esecuzione di Step Functions.

1. Nella ContinueAsNew pagina, scegli Avvia esecuzione.

   Viene visualizzata la finestra di dialogo Avvia esecuzione.

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

   1. (Facoltativo) Immettete un nome di esecuzione personalizzato per sovrascrivere il valore predefinito generato.

      Non-ASCII nomi e registrazione

      Step Functions accetta nomi per macchine a stati, esecuzioni, attività ed etichette che contengono caratteri non ASCII. Poiché tali caratteri impediranno ad Amazon di registrare i dati, consigliamo di utilizzare solo caratteri ASCII in modo CloudWatch da poter tenere traccia delle metriche di Step Functions.

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

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

   3. Aggiornare il campo StateMachineArn con l'ARN della macchina a stati ContinueAsNew.

   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, puoi esaminare i risultati dell'esecuzione man mano che l'esecuzione procede o al suo completamento.

      Per esaminare i risultati dell'esecuzione, scegli i singoli stati nella vista Grafico, quindi scegli 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, è 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.

      

      Al termine dell'esecuzione, puoi guardare la successiva esecuzione in esecuzione. Seleziona il ContinueAsNew link in alto per visualizzare l'elenco delle esecuzioni. Dovresti vedere sia l'esecuzione chiusa di recente, sia un'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.