Création d'une machine à états d'activité à l'aide de Step Functions

Dans la console Step Functions, dans le volet de navigation de gauche, choisissez Activities.

Choisissez Create activity (Créer une activité).

Entrez un nom pour l'activité, par exempleget-greeting, puis choisissez Créer une activité.

Lorsque votre tâche d'activité est créée, notez-laARN, comme indiqué dans l'exemple suivant.

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

Dans la console Step Functions, dans le volet de navigation de gauche, choisissez State machines.

Sur la page State machines, choisissez Create state machine.

Dans la boîte de dialogue Choisir un modèle, sélectionnez Vide.

Choisissez Sélectionner pour ouvrir Workflow Studio dansMode de conception.

Pour ce didacticiel, vous allez écrire la définition Amazon States Language (ASL) de votre machine à états dans l'éditeur de code. Pour ce faire, sélectionnez Code.

Supprimez le code standard existant et collez le code suivant. N'oubliez pas de remplacer l'exemple ARN de ce code par celui ARN de la tâche d'activité que vous avez créée précédemment dans le Resource champ.

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

Il s'agit d'une description de votre machine à états utilisant le Amazon States Language (ASL). Elle décrit un seul état Task nommé getGreeting. Pour plus d'informations, consultez Structure de la machine d'état.

Sur leVisualisation de graphe, assurez-vous que le graphique du flux de travail correspondant à la ASL définition que vous avez ajoutée ressemble au graphique suivant.

Spécifiez un nom pour votre machine à états. Pour ce faire, cliquez sur l'icône d'édition à côté du nom de la machine à états par défaut de MyStateMachine. Ensuite, dans Configuration de la machine d'état, spécifiez un nom dans le champ Nom de la machine d'état.

Pour ce didacticiel, saisissez le nom ActivityStateMachine.

(Facultatif) Dans Configuration de la machine à états, spécifiez d'autres paramètres de flux de travail, tels que le type de machine à états et son rôle d'exécution.

Pour ce didacticiel, conservez toutes les sélections par défaut dans les paramètres State Machine.

Si vous avez déjà créé un IAM rôle avec les autorisations appropriées pour votre machine d'état et que vous souhaitez l'utiliser, dans Autorisations, sélectionnez Choisir un rôle existant, puis sélectionnez un rôle dans la liste. Vous pouvez également sélectionner Entrer un rôle, ARN puis fournir un ARN pour ce IAM rôle.

Dans la boîte de dialogue Confirmer la création du rôle, choisissez Confirmer pour continuer.

Vous pouvez également choisir Afficher les paramètres des rôles pour revenir à la configuration de la machine State.

Créez un fichier nommé GreeterActivities.java.

Ajoutez-lui le code suivant.

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

Dans la liste des paramètres du GetActivityTaskRequest().withActivityArn() constructeur, remplacez la ACTIVITY_ARN valeur par celle de la tâche ARN d'activité que vous avez créée précédemment.

Dans la page ActivityStateMachinepage, choisissez Démarrer l'exécution.

La boîte de dialogue Démarrer l'exécution s'affiche.

Dans la boîte de dialogue Démarrer l'exécution, procédez comme suit :

1. (Facultatif) Entrez un nom d'exécution personnalisé pour remplacer le nom par défaut généré.

   ASCIINon-noms et journalisation

   Step Functions accepte les noms des machines d'état, des exécutions, des activités et des étiquettes contenant des caractères autres que des ASCII caractères. Comme ces caractères ne fonctionneront pas avec Amazon CloudWatch, nous vous recommandons de n'utiliser que des ASCII caractères afin de pouvoir suivre les statistiques CloudWatch.

2. Dans la zone de saisie, entrez l'JSONentrée suivante pour exécuter votre flux de travail.

   {
     "who": "AWS Step Functions"
   }

3. Choisissez Start execution (Démarrer l'exécution).

4. La console Step Functions vous dirige vers une page intitulée avec votre ID d'exécution. Cette page est connue sous le nom de page Détails de l'exécution. Sur cette page, vous pouvez consulter les résultats de l'exécution au fur et à mesure que l'exécution progresse ou une fois celle-ci terminée.

   Pour consulter les résultats de l'exécution, choisissez des états individuels dans la vue graphique, puis choisissez les onglets individuels du Détails de l'étape volet pour afficher les détails de chaque état, y compris les entrées, les sorties et la définition respectivement. Pour plus de détails sur les informations d'exécution que vous pouvez consulter sur la page Détails de l'exécution, voirVue d'ensemble des détails d'exécution.

Sur la ligne de commande, accédez au répertoire dans lequel vous avez créé GreeterActivities.java.

Pour utiliser le plugin AWS SDK, ajoutez le chemin complet des third-party répertoires lib et aux dépendances de votre fichier de compilation et à votre JavaCLASSPATH. Pour plus d'informations, voir Téléchargement et extraction SDK du AWS SDK for Java Guide du développeur.

Compilez le fichier.

$ javac GreeterActivities.java

Exécutez le fichier .

$ java GreeterActivities

Sur la console Step Functions, accédez à la page Détails de l'exécution.

Lorsque l'exécution est terminée, examinez les résultats de votre exécution.

Arrêtez l'application de travail.