Étape 1 : créer la machine à états et provisionner les ressources Étape 2 : Exécuter la machine à états À propos de la machine à états et de son exécution Exemples IAM

Exemple d'orchestration Lambda

Cet exemple de projet montre comment intégrer des AWS Lambda fonctions dans les machines d'état Step Functions.

Dans ce projet, Step Functions utilise les fonctions Lambda pour vérifier le cours d'une action et déterminer une recommandation d'achat ou de vente. L'utilisateur reçoit ensuite cette recommandation et peut choisir d'acheter ou de vendre l'action. Le résultat de la transaction est renvoyé via une rubrique SNS.

Pour plus d'informations sur les intégrations de services Step Functions, consultez les rubriques suivantes :

Utilisation AWS Step Functions avec d'autres services
Politiques IAM pour :

Note

Cet exemple de projet peut entraîner des frais.

Pour AWS les nouveaux utilisateurs, un niveau d'utilisation gratuit est disponible. Dans cette offre, les services sont gratuits en-dessous d'un certain niveau d'utilisation. Pour plus d'informations sur AWS les coûts et le niveau gratuit, consultez la section Tarification.

Étape 1 : créer la machine à états et provisionner les ressources

Ouvrez la console Step Functions et choisissez Create state machine.
Tapez Orchestrate Lambda functions dans la zone de recherche, puis choisissez Orchestrate Lambda functions dans les résultats de recherche renvoyés.
Choisissez Next (Suivant) pour continuer.
Step Functions répertorie les Services AWS éléments utilisés dans l'exemple de projet que vous avez sélectionné. Il montre également un graphique de flux de travail pour l'exemple de projet. Déployez ce projet sur votre site Compte AWS ou utilisez-le comme point de départ pour créer vos propres projets. Selon la façon dont vous souhaitez procéder, choisissez Exécuter une démo ou Construire à partir de celle-ci.

Cet exemple de projet déploie les ressources suivantes :
- Cinq Lambda fonctions
- Une file d'attente Amazon Simple Queue Service
- Une rubrique Amazon Simple Notification Service
- Machine d'état AWS Step Functions
- Rôles AWS Identity and Access Management (IAM) connexes
L'image suivante montre le graphique du flux de travail pour l'exemple de projet Orchestrate Lambda Functions :
Choisissez Utiliser le modèle pour poursuivre votre sélection.
Effectuez l’une des actions suivantes :
- Si vous avez sélectionné Build on it, Step Functions crée le prototype de flux de travail pour l'exemple de projet que vous avez sélectionné. Step Functions ne déploie pas les ressources répertoriées dans la définition du flux de travail.
  
  Dans Workflow StudioMode de conception, glissez-déposez les états depuis le Navigateur d'états pour continuer à créer votre prototype de flux de travail. Vous pouvez également passer à un éditeur de code intégré similaire à VS Code pour mettre à jour la définition Amazon States Language (ASL) de votre machine à états dans la console Step Functions. Mode code Pour plus d'informations sur l'utilisation de Workflow Studio pour créer vos machines d'état, consultezUtilisation de Workflow Studio.
  
  Important
  N'oubliez pas de mettre à jour l'espace réservé Amazon Resource Name (ARN) pour les ressources utilisées dans l'exemple de projet avant d'exécuter votre flux de travail.
- Si vous avez sélectionné Run a demo, Step Functions crée un exemple de projet en lecture seule qui utilise un AWS CloudFormation modèle pour déployer les AWS ressources répertoriées dans ce modèle sur votre. Compte AWS
  
  Astuce
  Pour afficher la définition de la machine à états de l'exemple de projet, choisissez Code.
  
  Lorsque vous êtes prêt, choisissez Déployer et exécuter pour déployer l'exemple de projet et créer les ressources.
  
  La création de ces ressources et des autorisations IAM associées peut prendre jusqu'à 10 minutes. Pendant le déploiement de vos ressources, vous pouvez ouvrir le lien CloudFormation Stack ID pour voir quelles ressources sont mises en service.
  
  Une fois que toutes les ressources de l'exemple de projet ont été créées, vous pouvez voir le nouvel exemple de projet répertorié sur la page State machines.
  
  Important
  Des frais standard peuvent s'appliquer pour chaque service utilisé dans le CloudFormation modèle.

Étape 2 : Exécuter la machine à états

Une fois que toutes les ressources ont été mises en service et déployées, la boîte de dialogue Démarrer l'exécution s'affiche.

Sur la page State machines, choisissez votre exemple de projet.
Sur la page d'exemple de projet, choisissez Démarrer l'exécution.
Dans la boîte de dialogue Démarrer l'exécution, procédez comme suit :
1. (Facultatif) Pour identifier votre exécution, vous pouvez lui donner un nom dans le champ Nom. Par défaut, Step Functions génère automatiquement un nom d'exécution unique.
  
  Note
  Step Functions vous permet de créer des noms pour les machines d'état, les exécutions et les activités, ainsi que des étiquettes contenant des caractères non ASCII. Ces noms non ASCII ne fonctionnent pas avec Amazon. CloudWatch Pour être sûr de pouvoir suivre CloudWatch les métriques, choisissez un nom qui utilise uniquement des caractères ASCII.
2. (Facultatif) Dans la zone de saisie, entrez les valeurs d'entrée au format JSON pour exécuter votre flux de travail.
  
  Si vous avez choisi d'exécuter une démo, vous n'avez pas besoin de fournir d'entrée d'exécution.
  
  Note
  Si le projet de démonstration que vous avez déployé contient des données d'entrée d'exécution préremplies, utilisez ces entrées pour exécuter la machine à états.
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, voirPage de détails d'exécution — Vue d'ensemble de l'interface.

À propos de la machine à états et de son exécution

Dans cet exemple de projet, la machine à états s'intègre AWS Lambda en transmettant des paramètres directement à ces ressources, utilise une file d'attente Amazon SQS pour gérer la demande d'approbation humaine et utilise une rubrique Amazon SNS pour renvoyer les résultats de la requête.

Une exécution de Step Functions reçoit un texte JSON en entrée et transmet cette entrée au premier état du flux de travail. Les états individuels reçoivent des données JSON en entrée et transmettent généralement les données JSON en sortie à l'état suivant. Dans cet exemple de projet, le résultat de chaque étape est transmis en entrée à l'étape suivante du flux de travail. Par exemple, l'étape de recommandation Generate Buy/Sell reçoit le résultat de l'étape Vérifier le cours des actions en entrée. En outre, le résultat de l'étape de recommandation d'achat/vente est transmis en entrée à l'étape suivante, Request Human Approval, qui imite une étape d'approbation humaine.

Note

Pour afficher le résultat renvoyé par une étape et l'entrée transmise à une étape, ouvrez la page Détails de l'exécution pour l'exécution de votre flux de travail. Dans la section Détails de l'étape, visualisez l'entrée et la sortie de chaque étape sélectionnée en mode Affichage.

Pour implémenter une étape d'approbation humaine, vous interrompez généralement l'exécution du flux de travail jusqu'à ce qu'un jeton de tâche soit renvoyé. Dans cet exemple de projet, un message est transmis à une file d'attente Amazon SQS, qui est utilisée comme déclencheur de la fonction Lambda définie pour gérer la fonctionnalité de rappel. Le message contient un jeton de tâche et le résultat renvoyé par l'étape précédente. La fonction Lambda est invoquée avec la charge utile du message. L'exécution du flux de travail est suspendue jusqu'à ce qu'il reçoive le jeton de tâche en retour avec un appel d'SendTaskSuccessAPI. Pour plus d'informations sur les jetons de tâches, consultezAttendre un rappel avec le jeton de tâche.

Le code suivant pour la StepFunctionsSample-HelloLambda-ApproveSqsLambda fonction montre comment elle est définie pour approuver automatiquement toutes les tâches soumises par la file d'attente Amazon SQS via la machine d'état Step Functions.


exports.lambdaHandler = (event, context, callback) => {
  const stepfunctions = new aws.StepFunctions();

  // For every record in sqs queue
  for (const record of event.Records) {
      const messageBody = JSON.parse(record.body);
      const taskToken = messageBody.TaskToken;

      const params = {
          output: "\"approved\"",
          taskToken: taskToken
      };

      console.log(`Calling Step Functions to complete callback task with params ${JSON.stringify(params)}`);

      // Approve
      stepfunctions.sendTaskSuccess(params, (err, data) => {
          if (err) {
              console.error(err.message);
              callback(err.message);
              return;
          }
          console.log(data);
          callback(null);
      });
  }
};

Parcourez cet exemple de machine à états pour découvrir comment Step Functions contrôle Lambda et Amazon SQS.

Pour plus d'informations sur la manière de AWS Step Functions contrôler d'autres AWS services, consultezUtilisation AWS Step Functions avec d'autres services.


{
    "StartAt": "Check Stock Price",
    "States": {
        "Check Stock Price": {
            "Type": "Task",
            "Resource": "arn:aws:lambda:us-west-1:111122223333:function:StepFunctionsSample-HelloLam-CheckStockPriceLambda-444455556666",
            "Next": "Generate Buy/Sell recommendation"
        },
        "Generate Buy/Sell recommendation": {
            "Type": "Task",
            "Resource": "arn:aws:lambda:us-west-1:111122223333:function:StepFunctionsSample-Hello-GenerateBuySellRecommend-123456789012",
            "ResultPath": "$.recommended_type",
            "Next": "Request Human Approval"
        },
        "Request Human Approval": {
            "Type": "Task",
            "Resource": "arn:aws:states:::sqs:sendMessage.waitForTaskToken",
            "Parameters": {
                "QueueUrl": "https://sqs.us-west-1.amazonaws.com/111122223333/StepFunctionsSample-HelloLambda4444-5555-6666-RequestHumanApprovalSqs-777788889999",
                "MessageBody": {
                    "Input.$": "$",
                    "TaskToken.$": "$$.Task.Token"
                }
            },
            "ResultPath": null,
            "Next": "Buy or Sell?"
        },
        "Buy or Sell?": {
            "Type": "Choice",
            "Choices": [
                {
                    "Variable": "$.recommended_type",
                    "StringEquals": "buy",
                    "Next": "Buy Stock"
                },
                {
                    "Variable": "$.recommended_type",
                    "StringEquals": "sell",
                    "Next": "Sell Stock"
                }
            ]
        },
        "Buy Stock": {
            "Type": "Task",
            "Resource": "arn:aws:lambda:us-west-1:111122223333:function:StepFunctionsSample-HelloLambda-BuyStockLambda-000000000000",
            "Next": "Report Result"
        },
        "Sell Stock": {
            "Type": "Task",
            "Resource": "arn:aws:lambda:us-west-1:111122223333:function:StepFunctionsSample-HelloLambda-SellStockLambda-111111111111",
            "Next": "Report Result"
        },
        "Report Result": {
            "Type": "Task",
            "Resource": "arn:aws:states:::sns:publish",
            "Parameters": {
                "TopicArn": "arn:aws:sns:us-west-1:111122223333:StepFunctionsSample-HelloLambda1111-2222-3333-ReportResultSnsTopic-222222222222",
                "Message": {
                    "Input.$": "$"
                }
            },
            "End": true
        }
    }
}

Pour plus d'informations sur la configuration de l'IAM lors de l'utilisation de Step Functions avec d'autres AWS services, consultezPolitiques IAM pour les services intégrés.

Exemples IAM

Ces exemples de politiques AWS Identity and Access Management (IAM) générés par l'exemple de projet incluent le moindre privilège nécessaire pour exécuter la machine à états et les ressources associées. Nous vous recommandons de n'inclure que les autorisations nécessaires dans vos politiques IAM.


{
    "Statement": [
        {
            "Action": [
                "lambda:InvokeFunction"
            ],
            "Resource": "arn:aws:lambda:us-west-1:111122223333:function:StepFunctionsSample-HelloLam-CheckStockPriceLambda-444455556666",
            "Effect": "Allow"
        }
    ]
}


{
    "Statement": [
        {
            "Action": [
                "lambda:InvokeFunction"
            ],
            "Resource": "arn:aws:lambda:us-west-1:111122223333:function:StepFunctionsSample-Hello-GenerateBuySellRecommend-123456789012",
            "Effect": "Allow"
        }
    ]
}


{
    "Statement": [
        {
            "Action": [
                "lambda:InvokeFunction"
            ],
            "Resource": "arn:aws:lambda:us-west-1:111122223333:function:StepFunctionsSample-HelloLambda-BuyStockLambda-777788889999",
            "Effect": "Allow"
        }
    ]
}


{
    "Statement": [
        {
            "Action": [
                "lambda:InvokeFunction"
            ],
            "Resource": "arn:aws:lambda:us-west-1:111122223333:function:StepFunctionsSample-HelloLambda-SellStockLambda-000000000000",
            "Effect": "Allow"
        }
    ]
}


{
    "Statement": [
        {
            "Action": [
                "sqs:SendMessage*"
            ],
            "Resource": "arn:aws:sqs:us-west-1:111122223333:StepFunctionsSample-HelloLambda4444-5555-6666-RequestHumanApprovalSqs-111111111111",
            "Effect": "Allow"
        }
    ]
}


{
    "Statement": [
        {
            "Action": [
                "sns:Publish"
            ],
            "Resource": "arn:aws:sns:us-west-1:111122223333:StepFunctionsSample-HelloLambda1111-2222-3333-ReportResultSnsTopic-222222222222",
            "Effect": "Allow"
        }
    ]
}

Pour plus d'informations sur la configuration de l'IAM lors de l'utilisation de Step Functions avec d'autres AWS services, consultezPolitiques IAM pour les services intégrés.

Avertissement JavaScript est désactivé ou n'est pas disponible dans votre navigateur.

Pour que vous puissiez utiliser la documentation AWS, Javascript doit être activé. Vous trouverez des instructions sur les pages d'aide de votre navigateur.

Conventions de rédaction

Prétraitez les données et entraînez un modèle d'apprentissage automatique

Lancer une requête Athena

Exemple d'orchestration Lambda

Note

Étape 1 : créer la machine à états et provisionner les ressources

Important

Astuce

Important

Étape 2 : Exécuter la machine à états

Note

Note

À propos de la machine à états et de son exécution

Note

Exemples IAM