Ajoutez une logique conditionnelle à votre flux de travail Step Functions

1. Ouvrez la SNSconsole Amazon et créez un type de sujet standard. Pour plus d'informations sur la création d'un sujet, consultez la section Créer un SNS sujet Amazon dans le manuel Amazon Simple Notification Service Developer Guide.

2. Spécifiez le nom du sujet sous la formeTaskTokenTopic.

3. Assurez-vous de copier le sujet ARN et de l'enregistrer dans un fichier texte. Vous aurez besoin de cette rubrique ARN pour spécifier l'intégration des services pour l'état Attendre l'approbation humaine. Voici un exemple de sujet ARN :

   arn:aws:sns:us-east-2:123456789012:TaskTokenTopic

4. Créez un abonnement par e-mail pour le sujet, puis confirmez votre abonnement. Pour plus d'informations sur l'abonnement à un sujet, consultez la section Créer un abonnement au sujet dans le manuel Amazon Simple Notification Service Developer Guide.

1. Dans un nouvel onglet ou une nouvelle fenêtre, ouvrez la console Lambda et créez une fonction Lambda Node.js intitulée. callback-human-approval Pour plus d'informations sur la création d'une fonction Lambda à l'aide de la console, voir Créer une fonction Lambda dans la console dans le AWS Lambda Guide du développeur.

2. Sur la callback-human-approvalpage, remplacez le code existant dans la zone Source du code par le code suivant.

   // Lambda function that will automatically approve any task 
   // in a message published to an Amazon SNS topic
   
   console.log('Loading function');
   const AWS = require('aws-sdk');
   const resultMessage = "Successful";
   
   export const handler = async (event) => {
       const stepfunctions = new AWS.StepFunctions();
       
       let message = JSON.parse(event.Records[0].Sns.Message);
       let taskToken = message.TaskToken;
       
       console.log('Message received from SNS:', message); 
       console.log('Task token: ', taskToken);
       
       // Return task token to Step Functions
       
       let params = {
           output: JSON.stringify(resultMessage),
           taskToken: taskToken
       };
       
       console.log('JSON Returned to Step Functions: ', params);
       let myResult = await stepfunctions.sendTaskSuccess(params).promise();
       console.log('State machine - callback completed..');
       
       return myResult;
       
   };

3. Gardez cette fenêtre ouverte et suivez les étapes de la section suivante pour effectuer d'autres actions.

1. Dans la section Vue d'ensemble des fonctions de la fonction callback-human-approval Lambda, choisissez Ajouter un déclencheur.

2. Dans la liste déroulante des déclencheurs, choisissez-en un SNScomme déclencheur.

3. Pour le SNSsujet, commencez à saisir le nom du SNS sujet Amazon que vous avez créé à l'étape 1 de ce didacticiel, puis choisissez-le dans la liste déroulante qui apparaît.

4. Choisissez Ajouter.

5. Gardez cette fenêtre ouverte et suivez les étapes de la section suivante pour effectuer d'autres actions.

1. Sur la callback-human-approvalpage, choisissez l'onglet Configuration, puis sélectionnez Autorisations.

2. Sous Rôle d'exécution, choisissez le nom du rôle pour accéder au AWS Identity and Access Management page Rôles de la console.

3. Pour ajouter l'autorisation requise, choisissez Ajouter des autorisations, puis choisissez Joindre des politiques.

4. Dans le champ de recherche, tapez AWSStepFunctions puis appuyez sur Entrée.

5. Choisissez AWSStepFunctionsFullAccesspuis faites défiler l'écran vers le bas pour sélectionner Joindre des politiques. Cela ajoute la politique contenant les autorisations nécessaires pour le rôle de fonction callback-human-approval Lambda.

Pour ajouter une logique de condition if-else à l'aide de l'état Choice

1. Ouvrez la fenêtre de console Step Functions contenant le prototype de flux de travail que vous avez crééCréer une machine d'état.

2. Choisissez le crédit appliqué >= 5000 ? état et dans l'onglet Configuration, spécifiez la logique conditionnelle comme suit :

   1. Sous Règles de choix, cliquez sur l'icône Modifier dans la vignette Règle #1 pour définir la règle du premier choix.

   2. Sélectionnez Ajouter des conditions.

   3. Dans la boîte de dialogue Conditions pour la règle #1, pour Variable, entrez$.

   4. Pour Opérateur, le choix est inférieur à.

   5. Pour Valeur, choisissez Constante numérique, puis entrez 5000 dans le champ situé à côté de la liste déroulante Valeur.

   6. Choisissez Enregistrer les conditions.

   7. Pour la liste déroulante « L'état suivant est : », choisissez « Approuver automatiquement la limite ».

   8. Choisissez Ajouter une nouvelle règle de choix, puis définissez la deuxième règle de choix lorsque le montant du crédit est supérieur ou égal à 5 000 en répétant les sous-étapes 2.b à 2.f. Pour Operator, le paramètre choose est supérieur ou égal à.

   9. Pour la liste déroulante L'état suivant est :, choisissez Attendre l'approbation humaine.

   10. Dans la zone Règle par défaut, cliquez sur l'icône Modifier pour définir la règle de choix par défaut, puis choisissez Attendre l'approbation humaine dans la liste déroulante État par défaut. Vous définissez la règle par défaut pour spécifier le prochain état vers lequel passer si aucune des conditions de l'état Choice n'est vraie ou fausse.

3. Configurez l'état Attendre l'approbation humaine comme suit :

   1. Dans l'onglet Configuration, pour Rubrique, commencez à saisir le nom de la SNS rubrique Amazon TaskTokenTopic, puis choisissez le nom tel qu'il apparaît dans la liste déroulante.

   2. Pour Message, choisissez Entrer un message dans la liste déroulante. Dans le champ Message, vous spécifiez le message que vous souhaitez publier dans le SNS sujet Amazon. Pour ce didacticiel, vous publiez un jeton de tâche en tant que message.

      Un jeton de tâche vous permet de suspendre un flux de travail Step Functions de type standard jusqu'à ce qu'un processus externe soit terminé et que le jeton de tâche soit renvoyé. Lorsque vous spécifiez un état de tâche en tant que tâche de rappel en spécifiant le modèle d'intégration du .waitForTaskToken service, un jeton de tâche est généré et placé dans l'objet de contexte au démarrage de la tâche. L'objet de contexte est une JSON structure interne disponible lors d'une exécution et contenant des informations sur votre machine à états et son exécution. Pour plus d'informations sur les objets contextuels, consultezObjet Contexte.

   3. Dans le champ qui apparaît, entrez le message suivant :

      {
        "TaskToken.$": "$$.Task.Token"
      }

   4. Cochez la case Attendre le rappel.

   5. Choisissez OK dans la boîte de dialogue qui apparaît.

4. Gardez cette fenêtre ouverte et passez à la rubrique suivante.