Lambda 함수를 사용하여 Step Functions에서 새 실행 계속

1. Lambda 콘솔을 열고 함수 생성을 선택합니다.

2. 함수 생성 페이지에서 처음부터 새로 작성을 선택합니다.

3. 기본 정보 섹션에서 다음과 같이 Lambda 함수를 구성합니다.

   1. [함수 이름]에 Iterator을 입력합니다.

   2. 런타임에는 Node.js 16.x를 선택합니다.

   3. 페이지에 있는 모든 기본 선택 항목을 그대로 두고 함수 생성을 선택합니다.

      Lambda 함수가 생성되면 페이지 오른쪽 상단 모서리에 다음과 같이 Amazon 리소스 이름(ARN)을 기록해 둡니다.

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

4. Lambda 함수에 대한 다음 코드를 의 코드 소스 섹션에 복사합니다. Iterator Lambda 콘솔의 페이지.

   exports.handler = function iterator (event, context, callback) {
     let index = event.iterator.index;
     let step = event.iterator.step;
     let count = event.iterator.count;
    
     index = index + step;
    
     callback(null, {
       index,
       step,
       count,
       continue: index < count
     })
   }

   이 코드는 count, index 및 step에 대한 입력값을 수신합니다. 이 코드는 index를 step 값만큼 증가시키고 이들 값과 continue 부울 값을 반환합니다. index가 count보다 작으면 continue 값이 true입니다.

5. 배포를 선택하여 코드를 배포합니다.

1. 테스트 이벤트 구성 대화 상자에서 새로운 테스트 이벤트 생성을 선택한 다음 이벤트 이름에 TestIterator를 입력합니다.

2. 예제 데이터를 다음으로 바꿉니다.

   {
     "Comment": "Test my Iterator function",
     "iterator": {
       "count": 10,
       "index": 5,
       "step": 1
     }
   }
   

   이러한 값은 반복 도중에 상태 머신에서 얻게 되는 내용처럼 보입니다. Lambda 함수는 인덱스를 증가시키고 continue를 true로 반환합니다. 인덱스가 count보다 작지 않으면 이 함수는 continue를 false로 반환합니다. 이 테스트에서는 인덱스가 이미 5까지 증가한 상태입니다. 결과는 index를 6으로 증가시키고 continue를 true로 설정해야 합니다.

3. 생성(Create)을 선택합니다.

4. 에서 반복자 Lambda 콘솔의 페이지에서 이 나열TestIterator되었는지 확인한 다음 테스트를 선택합니다.

   테스트의 결과는 창 위쪽에 표시됩니다. [Details]를 선택하고 결과를 검토합니다.

   {
     "index": 6,
     "step": 1,
     "count": 10,
     "continue": true
   }
   

   참고

   이 테스트에서 index를 9로 설정할 경우 index는 10으로 증가하고 continue는 false가 됩니다.

1. Lambda 콘솔을 열고 함수 생성을 선택합니다.

2. 함수 생성 페이지에서 처음부터 새로 작성을 선택합니다.

3. 기본 정보 섹션에서 다음과 같이 Lambda 함수를 구성합니다.

   1. [함수 이름]에 Restart을 입력합니다.

   2. 런타임에는 Node.js 16.x를 선택합니다.

4. 페이지에 있는 모든 기본 선택 항목을 그대로 두고 함수 생성을 선택합니다.

   Lambda 함수가 생성되면 페이지 오른쪽 상단 모서리에 다음과 같이 Amazon 리소스 이름(ARN)을 기록해 둡니다.

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

5. Lambda 함수에 대한 다음 코드를 의 코드 소스 섹션에 복사합니다. Restart Lambda 콘솔의 페이지.

   다음 코드는 실행 수 카운트를 감소시키고 감소된 값을 포함하여 상태 머신의 새 실행을 시작합니다.

   var aws = require('aws-sdk');
   var sfn = new aws.StepFunctions();
   
   exports.restart = function(event, context, callback) {
   
     let StateMachineArn = event.restart.StateMachineArn;
     event.restart.executionCount -= 1;
     event = JSON.stringify(event);
   
     let params = {
         input: event,
         stateMachineArn: StateMachineArn
     };
   
     sfn.startExecution(params, function(err, data) {
         if (err) callback(err);
         else callback(null,event);
     });
   
   }

6. 배포를 선택하여 코드를 배포합니다.

상태 시스템을 생성하려면

1. Step Functions 콘솔을 열고 상태 시스템 생성을 선택합니다.

   중요

   상태 시스템이 1단계 및 2단계에서 이전에 생성한 Lambda 함수와 동일한 AWS 계정 및 리전에 있는지 확인합니다.

2. 템플릿 선택 대화 상자에서 공백을 선택합니다.

3. 선택을 선택하여 에서 Workflow Studio를 엽니다디자인 모드.

4. 이 자습서에서는 에 상태 시스템의 Amazon States Language (ASL) 정의를 작성합니다코드 편집기. 이렇게 하려면 코드를 선택합니다.

5. 기존 보일러플레이트 코드를 제거하고 다음 코드를 붙여넣습니다. 이 코드ARNs의 를 생성한 Lambda 함수ARNs의 로 교체해야 합니다.

   {
       "Comment": "Continue-as-new State Machine Example",
       "StartAt": "ConfigureCount",
       "States": {
           "ConfigureCount": {
               "Type": "Pass",
               "Result": {
                   "count": 100,
                   "index": -1,
                   "step": 1
               },
               "ResultPath": "$.iterator",
               "Next": "Iterator"
           },
           "Iterator": {
               "Type": "Task",
               "Resource": "arn:aws:lambda:us-east-1:123456789012:function:Iterator",
               "ResultPath": "$.iterator",
               "Next": "IsCountReached"
           },
           "IsCountReached": {
               "Type": "Choice",
               "Choices": [
                   {
                       "Variable": "$.iterator.continue",
                       "BooleanEquals": true,
                       "Next": "ExampleWork"
                   }
               ],
               "Default": "ShouldRestart"
           },
           "ExampleWork": {
               "Comment": "Your application logic, to run a specific number of times",
               "Type": "Pass",
               "Result": {
                 "success": true
               },
               "ResultPath": "$.result",
               "Next": "Iterator"
           },
           "ShouldRestart": {
             "Type": "Choice",
             "Choices": [
               {
                 "Variable": "$.restart.executionCount",
                 "NumericGreaterThan": 0,
                 "Next": "Restart"
               }
             ],
             "Default": "Done"
           },
           "Restart": {
             "Type": "Task",
             "Resource": "arn:aws:lambda:us-east-1:123456789012:function:Restart",
             "Next": "Done"
           },
           "Done": {
               "Type": "Pass",
               "End": true 
           }
       }
   }

6. 상태 시스템 이름을 지정합니다. 이렇게 하려면 기본 상태 시스템 이름 옆의 편집 아이콘을 선택합니다MyStateMachine. 그런 다음 상태 머신 구성에서 상태 머신 이름 상자에 이름을 지정합니다.

   이 튜토리얼에서는 이름 ContinueAsNew를 입력합니다.

7. (선택 사항) 상태 머신 구성에서 상태 시스템 유형 및 실행 역할과 같은 기타 워크플로 설정을 지정합니다.

   이 자습서의 경우 상태 머신 설정의 모든 기본 선택 항목을 그대로 둡니다.

   이전에 상태 시스템에 대한 올바른 권한이 있는 IAM 역할을 생성하여 사용하려는 경우 권한 에서 기존 역할 선택을 선택한 다음 목록에서 역할을 선택합니다. 또는 역할 입력을 ARN 선택한 다음 해당 IAM 역할에 ARN 대한 를 제공합니다.

8. 역할 생성 확인 대화 상자에서 확인을 선택하여 계속합니다.

   역할 설정 보기를 선택하여 상태 머신 구성으로 돌아갈 수도 있습니다.

   참고

   Step Functions가 생성하는 IAM 역할을 삭제하면 Step Functions는 나중에 다시 생성할 수 없습니다. 마찬가지로 역할을 수정하는 경우(예: IAM 정책의 보안 주체에서 Step Functions를 제거하여), Step Functions는 나중에 원래 설정을 복원할 수 없습니다.

9. 이 상태 시스템의 Amazon 리소스 이름(ARN)을 텍스트 파일에 저장합니다. 새 Step Functions 실행을 시작하려면 Lambda 함수에 권한을 부여하는 ARN 동안 를 제공해야 합니다.

1. ContinueAsNew 페이지에서 실행 시작을 선택합니다.

   실행 시작 대화 상자가 표시됩니다.

2. 실행 시작 대화 상자에서 다음을 수행합니다.

   1. (선택 사항) 생성된 기본값을 재정의하려면 사용자 지정 실행 이름을 입력합니다.

      비ASCII이름 및 로깅

      Step Functions는 문자ASCII가 아닌 상태 시스템, 실행, 활동 및 레이블의 이름을 허용합니다. 이러한 문자는 Amazon 에서는 작동하지 않으므로 에서 지표를 추적할 수 있도록 ASCII 문자만 사용하는 CloudWatch것이 좋습니다 CloudWatch.

   2. 입력 상자에 다음 JSON 입력을 입력하여 워크플로를 실행합니다.

      {
        "restart": {
          "StateMachineArn": "arn:aws:states:us-east-1:123456789012:stateMachine:ContinueAsNew",
          "executionCount": 4
        }
      }
              

   3. ContinueAsNew 상태 시스템의 StateMachineArn 필드를 ARN 로 업데이트합니다.

   4. 실행 시작을 선택합니다.

   5. Step Functions 콘솔은 실행 ID가 제목인 페이지로 이동합니다. 이 페이지를 실행 세부 정보 페이지라고 합니다. 실행이 진행되는 동안 또는 완료된 후에 이 페이지에서 실행 결과를 검토할 수 있습니다.

      실행 결과를 검토하려면 그래프 보기에서 개별 상태를 선택한 다음 단계 세부 정보 창에서 개별 탭을 선택하여 입력, 출력 및 정의가 포함된 각 상태의 세부 정보를 각각 봅니다. 실행 세부 정보 페이지에서 볼 수 있는 실행 정보에 대한 자세한 내용은 실행 세부 정보 개요 섹션을 참조하세요.

      그래프 보기에는 실행 4개 중 첫 번째가 표시됩니다. 이 실행은 완료되기 전에 Restart 상태를 전달하고 새 실행을 시작합니다.

      

      이 실행이 완료되면 다음에 시작되는 실행을 볼 수 있습니다. 실행 목록을 보려면 상단의 ContinueAsNew 링크를 선택합니다. 최근에 종료된 실행과 Restart Lambda 함수가 시작된 진행 중인 실행이 모두 표시됩니다.

      모든 실행이 완료되면 네 개의 성공적인 실행이 목록에 표시됩니다. 첫 번째로 시작된 실행에는 선택한 이름이 표시되고, 후속 실행에는 생성된 이름이 표시됩니다.