통합 AWS Lambda SQS아마존과 아마존이 있는 Step Functions 스테이트 머신에서 SNS

이 샘플 프로젝트는 통합 방법을 보여줍니다. AWS Lambda Step Functions 스테이트 머신의 함수

이 프로젝트에서 Step Functions는 Lambda 함수를 사용하여 주가를 확인하고 추천 매수 또는 매도 거래를 결정합니다. 그런 다음 사용자에게 이 추천이 제공되고 사용자는 주식을 매수 또는 매도할지 선택할 수 있습니다. 거래 결과는 SNS 주제를 사용하여 반환됩니다.

Step Functions 서비스 통합에 대한 자세한 내용은 다음을 참조하세요.

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

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

2단계: 상태 시스템 실행

모든 리소스가 프로비저닝되고 배포되면 실행 시작 대화 상자가 표시됩니다.

상태 시스템 및 실행 정보

이 샘플 프로젝트의 상태 머신은 다음과 통합됩니다. AWS Lambda 해당 리소스에 파라미터를 직접 전달하여 Amazon SQS 대기열을 사용하여 사람의 승인 요청을 관리하고 Amazon SNS 주제를 사용하여 쿼리 결과를 반환합니다.

Step Functions 실행은 JSON 텍스트를 입력으로 받아 워크플로의 첫 번째 상태로 해당 입력을 전달합니다. 개별 상태는 JSON 데이터를 입력으로 받고 일반적으로 JSON 데이터를 다음 상태에 출력으로 전달합니다. 이 샘플 프로젝트에서는 각 단계의 출력이 입력으로 워크플로의 다음 단계에 전달됩니다. 예를 들어 구매/판매 추천 생성 단계에서는 주가 확인 단계 출력을 입력으로 수신합니다. 또한 구매/판매 추천 생성 단계 출력은 입력으로 사람의 승인 단계를 모방한 다음 단계인 사람 승인 요청으로 전달됩니다.

사람 승인 단계를 구현하려면 일반적으로 작업 토큰이 반환될 때까지 워크플로 실행을 일시 중지합니다. 이 샘플 프로젝트에서는 메시지가 Amazon SQS 대기열로 전달되며, 이 대기열은 콜백 기능을 처리하도록 정의된 Lambda 함수의 트리거로 사용됩니다. 메시지에는 작업 토큰과 이전 단계에서 반환한 출력이 포함됩니다. Lambda 함수는 메시지의 페이로드와 함께 간접적으로 호출됩니다. 워크플로 실행은 호출을 통해 작업 토큰을 다시 받을 때까지 일시 중지됩니다. SendTaskSuccessAPI 작업 토큰에 대한 자세한 내용은 태스크 토큰으로 콜백이 올 때까지 기다리세요. 섹션을 참조하세요.

다음 StepFunctionsSample-HelloLambda-ApproveSqsLambda 함수 코드는 Step Functions 상태 머신을 통해 Amazon SQS 대기열에 제출된 모든 작업을 자동으로 승인하도록 함수를 정의하는 방법을 보여줍니다.

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

이 예제 상태 머신을 살펴보고 Step Functions가 Lambda와 Amazon을 어떻게 제어하는지 알아보십시오. SQS

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

{
    "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
        }
    }
}

Step Functions를 다른 기능과 함께 사용할 IAM 때 구성하는 방법에 대한 자세한 내용은 AWS 서비스는 을 참조하십시오Step Functions가 통합 서비스를 위한 IAM 정책을 생성하는 방법.

IAM예시

이 예시 AWS Identity and Access Management 샘플 프로젝트에서 생성된 (IAM) 정책에는 상태 머신 및 관련 리소스를 실행하는 데 필요한 최소 권한이 포함됩니다. 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"
        }
    ]
}

Step Functions를 다른 기능과 함께 사용할 IAM 때 구성하는 방법에 대한 자세한 내용은 AWS 서비스는 을 참조하십시오Step Functions가 통합 서비스를 위한 IAM 정책을 생성하는 방법.