チュートリアル: 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 という名前をそれぞれ付けた 2 つの Lambda 関数を追加します。

1. 次のコードを GetFruitPrice Lambda 関数のコードソース領域にコピーします。

   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. 次のコードを CalculateAverage Lambda 関数のコードソース領域にコピーします。

   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. これら 2 つの 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"
    ]
}