Step Functions에서 Lambda 함수를 사용하여 개별 항목 처리

• 다음 정의를 사용하여 Step Functions 콘솔로 상태 시스템을 만듭니다. 상태 시스템을 만드는 방법은 Distributed Map 상태 사용 시작하기 자습서의 1단계: 워크플로 프로토타입 만들기 섹션을 참조하세요.

  이 상태 시스템에서 정수 10개 배열을 입력으로 수락하고 이러한 배열 항목을 배치로 하위 워크플로 실행에 전달하는 Distributed Map 상태를 정의합니다. 각 하위 워크플로 실행은 항목 3개 배치를 입력으로 수신하고 Inline Map 상태를 실행합니다. Inline Map 상태가 반복될 때마다 Lambda 함수가 간접적으로 호출되고 배치의 항목이 함수로 전달됩니다. 그런 다음 이 함수는 항목에 승수 7을 곱하고 결과를 반환합니다.

  각 하위 워크플로 실행의 출력은 전달된 각 항목에 대한 곱셈 결과를 포함하는 JSON 배열입니다.

  중요

  다음 코드에 있는 Lambda 함수의 Amazon 리소스 이름 (ARN) 을 2단계에서 생성할 함수로 교체해야 합니다. ARN

  {
    "StartAt": "Pass",
    "States": {
      "Pass": {
        "Type": "Pass",
        "Next": "Map",
        "Result": {
          "MyMultiplicationFactor": 7,
          "MyItems": [1, 2, 3, 4, 5, 6, 7, 8, 9, 10]
        }
      },
      "Map": {
        "Type": "Map",
        "ItemProcessor": {
          "ProcessorConfig": {
            "Mode": "DISTRIBUTED",
            "ExecutionType": "STANDARD"
          },
          "StartAt": "InnerMap",
          "States": {
            "InnerMap": {
              "Type": "Map",
              "ItemProcessor": {
                "ProcessorConfig": {
                  "Mode": "INLINE"
                },
                "StartAt": "Lambda Invoke",
                "States": {
                  "Lambda Invoke": {
                    "Type": "Task",
                    "Resource": "arn:aws:states:::lambda:invoke",
                    "OutputPath": "$.Payload",
                    "Parameters": {
                      "Payload.$": "$",
                      "FunctionName": "arn:aws:lambda:us-east-1:123456789012:function:functionName"
                    },
                    "Retry": [
                      {
                        "ErrorEquals": [
                          "Lambda.ServiceException",
                          "Lambda.AWSLambdaException",
                          "Lambda.SdkClientException",
                          "Lambda.TooManyRequestsException"
                        ],
                        "IntervalSeconds": 2,
                        "MaxAttempts": 6,
                        "BackoffRate": 2
                      }
                    ],
                    "End": true
                  }
                }
              },
              "End": true,
              "ItemsPath": "$.Items",
              "ItemSelector": {
                "MyMultiplicationFactor.$": "$.BatchInput.MyMultiplicationFactor",
                "MyItem.$": "$$.Map.Item.Value"
              }
            }
          }
        },
        "End": true,
        "Label": "Map",
        "MaxConcurrency": 1000,
        "ItemsPath": "$.MyItems",
        "ItemBatcher": {
          "MaxItemsPerBatch": 3,
          "BatchInput": {
            "MyMultiplicationFactor.$": "$.MyMultiplicationFactor"
          }
        }
      }
    }
  }

Lambda 함수를 생성하려면

1. Lambda 콘솔을 사용하여 이름이 지정된 Python Lambda 함수를 생성합니다. ProcessSingleItem Lambda 함수를 만드는 방법은 Distributed Map 상태 사용 시작하기 자습서의 4단계: Lambda 함수 구성을 참조하세요.

2. Lambda 함수의 다음 코드를 복사하여 Lambda 함수의 코드 소스 섹션에 붙여넣습니다.

   import json
   
   def lambda_handler(event, context):
       
       multiplication_factor = event['MyMultiplicationFactor']
       item = event['MyItem']
       
       result = multiplication_factor * item
       
       return {
           'statusCode': 200,
           'multiplied': result
       }

3. Lambda 함수를 생성한 후 페이지 오른쪽 상단에 표시된 함수를 ARN 복사합니다. 다음은 예시입니다. ARN 함수 이름 Lambda 함수 (이 경우에는) 의 이름입니다. ProcessSingleItem

   arn:aws:lambda:us-east-1:123456789012:function:function-name

   1단계에서 생성한 상태 ARN 머신에 함수를 제공해야 합니다.

4. 배포를 선택하여 변경 사항을 배포합니다.