자습서: Step Functions에서의 스테이트 머신 실행 검사

Lambda 콘솔을 열고 1단계: Lambda 함수 생성 섹션의 1~4단계를 수행합니다. Lambda 함수 GetListOfFruits의 이름을 지정해야 합니다.

Lambda 함수를 생성한 후 페이지 오른쪽 상단에 표시된 함수의 Amazon 리소스 이름 ARN () 을 복사합니다. 를 복사하려면 복사 아이콘을 ARN 클릭하여 Lambda 함수의 Amazon 리소스 이름을 복사합니다. 다음은 ARN 예시입니다.함수 이름 Lambda 함수 (이 경우에는) 의 이름입니다. GetListOfFruits

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

Lambda 함수의 다음 코드를 페이지의 코드 소스 영역에 복사합니다. GetListOfFruits

function getRandomSubarray(arr, size) {
    var shuffled = arr.slice(0), i = arr.length, temp, index;
    while (i--) {
        index = Math.floor((i + 1) * Math.random());
        temp = shuffled[index];
        shuffled[index] = shuffled[i];
        shuffled[i] = temp;
    }
    return shuffled.slice(0, size);
}

exports.handler = async function(event, context) {
    
    const fruits = ['Abiu','Açaí','Acerola','Ackee','African cucumber','Apple','Apricot','Avocado','Banana','Bilberry','Blackberry','Blackcurrant','Jostaberry'];

    
     const errorChance = 45;
    
    const waitTime = Math.floor( 100 * Math.random() );

    await new Promise( r => setTimeout(() => r(), waitTime));

    const num = Math.floor( 100 * Math.random() );
    // const num = 51;
     if (num <= errorChance) {
         throw(new Error('Error'));
     }

    return getRandomSubarray(fruits, 4);
};

배포를 선택한 다음 테스트를 선택하여 변경 사항을 배포하고 Lambda 함수 출력을 확인합니다.

다음 단계에 따라 각각 GetFruitPrice 및 CalculateAverage라는 Lambda 함수 2개를 추가로 만듭니다.

1. 다음 코드를 GetFruitPriceLambda 함수의 코드 소스 영역에 복사합니다.

   exports.handler = async function(event, context) {
       
       const errorChance = 0;
       const waitTime = Math.floor( 100 * Math.random() );
   
       await new Promise( r => setTimeout(() => r(), waitTime));
   
       const num = Math.floor( 100 * Math.random() );
       if (num <= errorChance) {
           throw(new Error('Error'));
       }
   
       return Math.floor(Math.random()*100)/10;
   };

2. 다음 코드를 CalculateAverageLambda 함수의 코드 소스 영역에 복사합니다.

   function getRandomSubarray(arr, size) {
       var shuffled = arr.slice(0), i = arr.length, temp, index;
       while (i--) {
           index = Math.floor((i + 1) * Math.random());
           temp = shuffled[index];
           shuffled[index] = shuffled[i];
           shuffled[i] = temp;
       }
       return shuffled.slice(0, size);
   }
   
   const average = arr => arr.reduce( ( p, c ) => p + c, 0 ) / arr.length;
       
   exports.handler = async function(event, context) {
           const errors = [
           "Error getting data from DynamoDB",
           "Error connecting to DynamoDB",
           "Network error",
           "MemoryError - Low memory"
           ]
           
       const errorChance = 0;
       
       const waitTime = Math.floor( 100 * Math.random() );
   
       await new Promise( r => setTimeout(() => r(), waitTime));
   
       const num = Math.floor( 100 * Math.random() );
       if (num <= errorChance) {
           throw(new Error(getRandomSubarray(errors, 1)[0]));
       }
   
       return average(event);
   };

3. 이 두 Lambda 함수를 복사한 다음 배포하고 테스트하십시오. ARNs

Step Functions 콘솔을 열고 코드로 워크플로 작성을 선택합니다.

유형의 경우 기본 선택인 표준을 그대로 유지합니다.

다음 Amazon States Language 정의를 복사하여 정의 아래에 붙여넣습니다. ARNs표시된 내용을 이전에 생성한 Lambda 함수로 바꾸십시오.

{
    "StartAt": "LoopOverStores",
    "States": {
        "LoopOverStores": {
            "Type": "Map",
            "Iterator": {
                "StartAt": "GetListOfFruits",
                "States": {
                    "GetListOfFruits": {
                        "Type": "Task",
                        "Resource": "arn:aws:states:::lambda:invoke",
                        "OutputPath": "$.Payload",
                        "Parameters": {
                            "FunctionName": "arn:aws:lambda:us-east-1:123456789012:function:GetListofFruits:$LATEST",
                            "Payload": {
                                "storeName.$": "$"
                            }
                        },
                        "Retry": [
                            {
                                "ErrorEquals": [
                                    "States.ALL"
                                ],
                                "IntervalSeconds": 2,
                                "MaxAttempts": 1,
                                "BackoffRate": 1.3
                            }
                        ],
                        "Next": "LoopOverFruits"
                    },
                    "LoopOverFruits": {
                        "Type": "Map",
                        "Iterator": {
                            "StartAt": "GetFruitPrice",
                            "States": {
                                "GetFruitPrice": {
                                    "Type": "Task",
                                    "Resource": "arn:aws:states:::lambda:invoke",
                                    "OutputPath": "$.Payload",
                                    "Parameters": {
                                        "FunctionName": "arn:aws:lambda:us-east-1:123456789012:function:GetFruitPrice:$LATEST",
                                        "Payload": {
                                            "fruitName.$": "$"
                                        }
                                    },
                                    "Retry": [
                                        {
                                            "ErrorEquals": [
                                                "States.ALL"
                                            ],
                                            "IntervalSeconds": 2,
                                            "MaxAttempts": 3,
                                            "BackoffRate": 1.3
                                        }
                                    ],
                                    "End": true
                                }
                            }
                        },
                        "ItemsPath": "$",
                        "End": true
                    }
                }
            },
            "ItemsPath": "$.stores",
            "Next": "LoopOverStoreFruitsPrice",
            "ResultPath": "$.storesFruitsPrice"
        },
        "LoopOverStoreFruitsPrice": {
            "Type": "Map",
            "End": true,
            "Iterator": {
                "StartAt": "CalculateAverage",
                "States": {
                    "CalculateAverage": {
                        "Type": "Task",
                        "Resource": "arn:aws:states:::lambda:invoke",
                        "OutputPath": "$.Payload",
                        "Parameters": {
                            "FunctionName": "arn:aws:lambda:us-east-1:123456789012:function:Calculate-average:$LATEST",
                            "Payload.$": "$"
                        },
                        "Retry": [
                            {
                                "ErrorEquals": [
                                    "States.ALL"
                                ],
                                "IntervalSeconds": 2,
                                "MaxAttempts": 2,
                                "BackoffRate": 1.3
                            }
                        ],
                        "End": true
                    }
                }
            },
            "ItemsPath": "$.storesFruitsPrice",
            "ResultPath": "$.storesPriceAverage",
            "MaxConcurrency": 1
        }
    }
}

상태 시스템 이름을 입력합니다. 이 페이지의 다른 옵션을 기본 선택 사항으로 유지하고 상태 시스템 생성을 선택합니다.

제목이 상태 시스템 이름인 페이지를 엽니다. 4단계: 상태 시스템 실행 섹션의 1~4단계를 수행하되 실행 입력으로는 다음 데이터를 사용합니다.

{
    "stores": [
      "Store A",
      "Store B",
      "Store C",
      "Store D"
    ]
}