Crie um exemplo de padrão de retorno de chamada com Amazon SQSSNS, Amazon e Lambda

Este exemplo de projeto demonstra como ter AWS Step Functions faça uma pausa durante uma tarefa e espere que um processo externo retorne um token de tarefa que foi gerado quando a tarefa foi iniciada.

Quando esse projeto de exemplo é implantado, e uma execução é iniciada, as seguintes etapas ocorrem:

Para saber como implementar o padrão de retorno de chamada no Step Functions, consulte Aguarde um retorno de chamada com o token de tarefa.

Para obter mais informações sobre como AWS Step Functions pode controlar outros AWS serviços, vejaIntegrando serviços com Step Functions.

Etapa 1: Criar a máquina de estado

As próximas etapas dependem da sua escolha anterior:

Etapa 2: Executar a máquina de estado

Exemplo de Retorno de Chamada do Lambda

Para ver como os componentes desse projeto de amostra funcionam juntos, veja os recursos que foram implantados em seu AWS conta. Por exemplo, veja a seguir a função do Lambda que chama o Step Functions com o token de tarefa.

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