Créez un exemple de modèle de rappel avec Amazon SQSSNS, Amazon et Lambda

Cet exemple de projet montre comment avoir AWS Step Functions faites une pause pendant une tâche et attendez 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 un jeton de tâche.

Pour plus d'informations sur la façon dont AWS Step Functions peut contrôler d'autres AWS services, voirIntégrer les services avec Step Functions.

Étape 1 : Création de la machine à états

Les prochaines étapes dépendent de votre choix précédent :

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