Exemple de modèle de rappel (Amazon SQS, Amazon SNS, Lambda)

Cet exemple de projet montre comment faire une AWS Step Functions pause pendant une tâche et attendre qu'un processus externe renvoie un jeton de tâche généré au démarrage de la tâche.

Lorsque cet exemple de projet est déployé et qu'une exécution est démarrée, les étapes suivantes se produisent.

Pour savoir comment implémenter le modèle de rappel dans Step Functions, consultezAttendre un rappel avec le jeton de tâche.

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.

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

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

Exemple de rappel Lambda

Pour voir comment les composants de cet exemple de projet fonctionnent ensemble, consultez les ressources qui ont été déployées dans votre AWS compte. Par exemple, voici la fonction Lambda qui appelle Step Functions avec le jeton de tâche.

console.log('Loading function');
const aws = require('aws-sdk');

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

    for (const record of event.Records) {
        const messageBody = JSON.parse(record.body);
        const taskToken = messageBody.TaskToken;

        const params = {
            output: "\"Callback task completed successfully.\"",
            taskToken: taskToken
        };

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

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