AmazonSQS, AmazonSNS, Lambda를 사용하여 콜백 패턴 예제 만들기

이 샘플 프로젝트는 다음을 수행하는 방법을 보여줍니다. AWS Step Functions 작업 도중에 일시 중지하고 외부 프로세스가 작업 시작 시 생성된 작업 토큰을 반환할 때까지 기다립니다.

이 샘플 프로젝트를 배포하고 실행을 시작하면 다음 단계가 수행됩니다.

Step Functions에서 콜백 패턴을 구현하는 방법은 태스크 토큰으로 콜백이 올 때까지 기다리세요. 섹션을 참조하세요.

방법에 대한 자세한 내용은 AWS Step Functions 다른 사람을 제어할 수 있습니다. AWS 서비스, 참조Step Functions와 서비스 통합.

1단계: 상태 시스템 만들기

다음 단계는 이전 선택에 따라 달라집니다.

2단계: 상태 시스템 실행

Lamda 콜백 예제

이 샘플 프로젝트의 구성 요소가 함께 작동하는 방식을 보려면 프로젝트에 배포된 리소스를 확인하세요. AWS 계정. 예를 들어 다음은 작업 토큰을 사용하여 Step Functions를 직접적으로 호출하는 Lambda 함수입니다.

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