Creazione di una macchina a stati Activity utilizzando Step Functions

Nella console Step Functions, nel riquadro di navigazione a sinistra, scegli Attività.

ScegliereCreate activity (Crea attività).

Inserisci un nome per l'attività, ad esempioget-greeting, e quindi scegli Crea attività.

Quando viene creata l'attività, prendine notaARN, come illustrato nell'esempio seguente.

arn:aws:states:us-east-1:123456789012:activity:get-greeting

Nella console Step Functions, nel riquadro di navigazione a sinistra, scegli Macchine a stati.

Nella pagina Macchine a stati, scegli Crea macchina a stati.

Nella finestra di dialogo Scegli un modello, seleziona Vuoto.

Scegliete Seleziona per aprire Workflow Studio inmodalità di progettazione.

In questo tutorial, scriverai la definizione Amazon States Language (ASL) della tua macchina a stati nell'editor di codice. Per fare ciò, scegli Code.

Rimuovi il codice boilerplate esistente e incolla il codice seguente. Ricordati di sostituire l'esempio ARN contenuto in questo codice con quello ARN dell'attività che hai creato in precedenza nel campo. Resource

{
  "Comment": "An example using a Task state.",
  "StartAt": "getGreeting",
  "Version": "1.0",
  "TimeoutSeconds": 300,
  "States":
  {
    "getGreeting": {
      "Type": "Task",
      "Resource": "arn:aws:states:us-east-1:123456789012:activity:get-greeting",
      "End": true
    }
  }
}

Questa è una descrizione della vostra macchina a stati che utilizza il Amazon States Language (ASL). Definisce un singolo stato Task denominato getGreeting. Per ulteriori informazioni, consultare Struttura di una macchina a stati.

SulVisualizzazione dei grafi, assicurati che il grafico del flusso di lavoro per la ASL definizione che hai aggiunto sia simile al grafico seguente.

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

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

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.

Crea un file denominato GreeterActivities.java.

Aggiungervi il seguente codice.

import com.amazonaws.ClientConfiguration;
import com.amazonaws.auth.EnvironmentVariableCredentialsProvider;
import com.amazonaws.regions.Regions;
import com.amazonaws.services.stepfunctions.AWSStepFunctions;
import com.amazonaws.services.stepfunctions.AWSStepFunctionsClientBuilder;
import com.amazonaws.services.stepfunctions.model.GetActivityTaskRequest;
import com.amazonaws.services.stepfunctions.model.GetActivityTaskResult;
import com.amazonaws.services.stepfunctions.model.SendTaskFailureRequest;
import com.amazonaws.services.stepfunctions.model.SendTaskSuccessRequest;
import com.amazonaws.util.json.Jackson;
import com.fasterxml.jackson.databind.JsonNode;
import java.util.concurrent.TimeUnit;


public class GreeterActivities {

    public String getGreeting(String who) throws Exception {
        return "{\"Hello\": \"" + who + "\"}";
    }

    public static void main(final String[] args) throws Exception {
        GreeterActivities greeterActivities = new GreeterActivities();
        ClientConfiguration clientConfiguration = new ClientConfiguration();
        clientConfiguration.setSocketTimeout((int)TimeUnit.SECONDS.toMillis(70));

        AWSStepFunctions client = AWSStepFunctionsClientBuilder.standard()
                .withRegion(Regions.US_EAST_1)
                .withCredentials(new EnvironmentVariableCredentialsProvider())
                .withClientConfiguration(clientConfiguration)
                .build();

        while (true) {
            GetActivityTaskResult getActivityTaskResult =
                    client.getActivityTask(
                            new GetActivityTaskRequest().withActivityArn(ACTIVITY_ARN));

            if (getActivityTaskResult.getTaskToken() != null) {
                try {
                    JsonNode json = Jackson.jsonNodeOf(getActivityTaskResult.getInput());
                    String greetingResult =
                            greeterActivities.getGreeting(json.get("who").textValue());
                    client.sendTaskSuccess(
                            new SendTaskSuccessRequest().withOutput(
                                    greetingResult).withTaskToken(getActivityTaskResult.getTaskToken()));
                } catch (Exception e) {
                    client.sendTaskFailure(new SendTaskFailureRequest().withTaskToken(
                            getActivityTaskResult.getTaskToken()));
                }
            } else {
                Thread.sleep(1000);
            }
        }
    }
}

Nell'elenco dei parametri del GetActivityTaskRequest().withActivityArn() costruttore, sostituite il ACTIVITY_ARN valore con quello ARN dell'attività che avete creato in precedenza.

Sul ActivityStateMachinenella pagina, scegli Avvia esecuzione.

Viene visualizzata la finestra di dialogo Avvia esecuzione.

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

   {
     "who": "AWS Step Functions"
   }

3. Selezionare Start execution (Avvia esecuzione).

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

Dalla riga di comando, accedere alla directory in cui è stato creato GreeterActivities.java.

Per utilizzare nuovamente il plugin AWS SDK, aggiungi il percorso completo delle third-party directory lib and alle dipendenze del tuo file di build e al tuo Java. CLASSPATH Per ulteriori informazioni, consulta Scaricare ed estrarre il file nel SDK AWS SDK for Java Guida per gli sviluppatori.

Compilare il file.

$ javac GreeterActivities.java

Esegui il file .

$ java GreeterActivities

Nella console Step Functions, vai alla pagina Dettagli di esecuzione.

Al termine dell'esecuzione, esamina i risultati dell'esecuzione.

Arrestare il lavoratore.