기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.

# Step Functions에서 Lambda 함수를 사용하여 배치 데이터 처리
<a name="tutorial-itembatcher-param-task"></a>

이 자습서에서는 *Distributed Map 상태*의 [ItemBatcher(맵)](input-output-itembatcher.md) 필드를 사용하여 Lambda 함수 내 전체 항목 배치를 처리합니다. 배치마다 항목이 최대 3개까지 포함됩니다. *Distributed Map 상태*에서는 하위 워크플로 실행 4개를 시작합니다. 여기서 각 실행은 항목 3개를 처리하고 실행 하나는 단일 항목을 처리합니다. 각 하위 워크플로 실행은 배치에 있는 개별 항목을 반복하는 Lambda 함수를 간접적으로 호출합니다.

정수 배열에서 곱셈을 수행하는 상태 시스템을 만듭니다. 입력으로 제공하는 정수 배열은 `[1, 2, 3, 4, 5, 6, 7, 8, 9, 10]`이고 곱셈 인수는 `7`입니다. 그러면 이러한 정수에 7의 인수를 곱한 후 생성된 결과 배열은 `[7, 14, 21, 28, 35, 42, 49, 56, 63, 70]`입니다.

## 1단계: 상태 시스템 만들기
<a name="itembatcher-param-task-create-state-machine"></a>

이 단계에서는 [2단계](#itembatcher-param-task-config-resource)에서 만들 Lambda 함수에 전체 데이터 배치를 전달하는 상태 시스템의 워크플로 프로토타입을 만듭니다.
+ 다음 정의를 사용하여 [Step Functions 콘솔](https://console.aws.amazon.com/states/home?region=us-east-1#/)로 상태 시스템을 만듭니다. 상태 시스템을 만드는 방법은 [Distributed Map 상태 사용 시작하기](tutorial-map-distributed.md) 자습서의 [1단계: 워크플로 프로토타입 만들기](tutorial-map-distributed.md#use-dist-map-create-workflow) 섹션을 참조하세요.

  이 상태 시스템에서 정수 10개 배열을 입력으로 수락하고 이 배열을 `3`의 배치로 Lambda 함수에 전달하는 *Distributed Map 상태*를 정의합니다. Lambda 함수는 배치에 있는 개별 항목을 반복하고 `multiplied` 출력 배열을 반환합니다. 출력 배열에는 입력 배열에 전달된 항목에 수행된 곱셈의 결과가 포함됩니다.
**중요**  
다음 코드에 있는 Lambda 함수의 Amazon 리소스 이름(ARN)을 [2단계](#itembatcher-param-task-config-resource)에서 만들 함수의 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": "Lambda Invoke",
          "States": {
            "Lambda Invoke": {
              "Type": "Task",
              "Resource": "arn:aws:states:::lambda:invoke",
              "OutputPath": "$.Payload",
              "Parameters": {
                "Payload.$": "$",
                "FunctionName": "arn:aws:lambda:region:account-id:function:functionName"
              },
              "Retry": [
                {
                  "ErrorEquals": [
                    "Lambda.ServiceException",
                    "Lambda.AWSLambdaException",
                    "Lambda.SdkClientException",
                    "Lambda.TooManyRequestsException"
                  ],
                  "IntervalSeconds": 2,
                  "MaxAttempts": 6,
                  "BackoffRate": 2
                }
              ],
              "End": true
            }
          }
        },
        "End": true,
        "Label": "Map",
        "MaxConcurrency": 1000,
        "ItemBatcher": {
          "MaxItemsPerBatch": 3,
          "BatchInput": {
            "MyMultiplicationFactor.$": "$.MyMultiplicationFactor"
          }
        },
        "ItemsPath": "$.MyItems"
      }
    }
  }
  ```

## 2단계: Lambda 함수 만들기
<a name="itembatcher-param-task-config-resource"></a>

이 단계에서는 배치에서 전달된 모든 항목을 처리하는 Lambda 함수를 만듭니다.

**중요**  
Lambda 함수가 상태 시스템과 동일한 AWS 리전에 있는지 확인합니다.

**Lambda 함수를 만들려면**

1. [Lambda 콘솔](https://console.aws.amazon.com/lambda/home)을 사용하여 **ProcessEntireBatch**라는 **Python** Lambda 함수를 만듭니다. Lambda 함수를 만드는 방법은 [Distributed Map 상태 사용 시작하기](tutorial-map-distributed.md) 자습서의 [4단계: Lambda 함수 구성](tutorial-map-distributed.md#use-dist-map-config-resource)을 참조하세요.

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

   ```
   import json
   
   def lambda_handler(event, context):
       multiplication_factor = event['BatchInput']['MyMultiplicationFactor']
       items = event['Items']
       
       results = [multiplication_factor * item for item in items]
       
       return {
           'statusCode': 200,
           'multiplied': results
       }
   ```

1. Lambda 함수를 만든 후 페이지 오른쪽 상단에 표시된 함수의 ARN을 복사합니다. 다음은 예제 ARN입니다. 여기서 *`function-name`*은 Lambda 함수 이름입니다(이 경우 `ProcessEntireBatch`).

   ```
   arn:aws:lambda:region:123456789012:function:function-name
   ```

   [1단계](#itembatcher-param-task-create-state-machine)에서 만든 상태 시스템에 함수 ARN을 제공해야 합니다.

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

## 3단계: 상태 시스템 실행
<a name="itembatcher-param-task-run-state-machine"></a>

[상태 시스템](#itembatcher-param-task-create-state-machine)을 실행하면 *Distributed Map 상태*에서 하위 워크플로 실행 4개를 시작합니다. 여기서 각 실행은 항목 3개를 처리하고 실행 하나는 단일 항목을 처리합니다.

다음 예제에서는 하위 워크플로 실행 중 하나가 [`ProcessEntireBatch`](#itembatcher-param-task-config-resource) 함수에 전달한 데이터를 보여줍니다.

```
{
  "BatchInput": {
    "MyMultiplicationFactor": 7
  },
  "Items": [1, 2, 3]
}
```

이 입력이 제공되면 다음 예제에서는 Lambda 함수에서 반환한 `multiplied` 출력 배열을 보여줍니다.

```
{
  "statusCode": 200,
  "multiplied": [7, 14, 21]
}
```

상태 시스템에서 하위 워크플로 실행 4개에 대한 `multiplied` 배열 4개가가 포함된 다음 출력을 반환합니다. 이러한 배열에는 개별 입력 항목의 곱셈 결과가 포함됩니다.

```
[
  {
    "statusCode": 200,
    "multiplied": [7, 14, 21]
  },
  {
    "statusCode": 200,
    "multiplied": [28, 35, 42]
  },
  {
    "statusCode": 200,
    "multiplied": [49, 56, 63]
  },
  {
    "statusCode": 200,
    "multiplied": [70]
  }
]
```

반환된 모든 배열 항목을 단일 출력 배열로 결합하려면 [ResultSelector](input-output-inputpath-params.md#input-output-resultselector) 필드를 사용하면 됩니다. *Distributed Map 상태* 내에서 이 필드를 정의하여 모든 `multiplied` 배열을 찾고 이러한 배열 내의 모든 항목을 추출한 다음 단일 출력 배열로 결합합니다.

`ResultSelector` 필드를 사용하려면 다음 예제와 같이 상태 시스템 정의를 업데이트합니다.

```
{
  "StartAt": "Pass",
  "States": {
    ...
    ...
    "Map": {
      "Type": "Map",
      ...
      ...
      "ItemsPath": "$.MyItems",
      "ResultSelector": {
        "multiplied.$": "$..multiplied[*]"
      }
    }
  }
}
```

업데이트된 상태 시스템에서 다음 예제와 같이 통합된 출력 배열을 반환합니다.

```
{
  "multiplied": [7, 14, 21, 28, 35, 42, 49, 56, 63, 70]
}
```