Step Functions で Lambda 関数を使用してループを反復する

[Lambda console] (Lambda コンソール) にサインインし、[Create function] (関数の作成) を選択します。

[関数の作成] ページで、[一から作成] を選択します。

[ベーシック情報] セクションで、以下のように Lambda 関数を設定します。

1. [Function name] (関数名) に Iterator と入力します。

2. [ランタイム] で、[Node.js] を選択します。

3. [デフォルトの実行ロールの変更] で、[基本的な Lambda アクセス許可で新しいロールを作成] を選択します。

4. [Create function (関数の作成)] を選択します。

Lambda 関数の次のコードをコードソース にコピーします。

export const handler = function (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 です。

[デプロイ] を選択します。

[テスト] を選択します。

[テストイベントの設定] ダイアログボックスで、[イベント名] ボックスに TestIterator を入力します。

データ例を以下に置き換えます。

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

これらの値は、反復でステートマシンから返される値を表します。Lambda 関数はインデックスをインクリメントし、インデックスが より小さいcontinue場合に trueを返しますcount。このテストでは、インデックスは既に 5 に増分されています。テストは indexに増分6され、 continueに設定されますtrue。

[Create] (作成) を選択します。

テスト を選択して Lambda 関数をテストします。

テストの結果は [実行結果] タブに表示されます。

実行結果を表示するには、[出力] タブを選択します。

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

Step Functions コンソールを開き、[Create a state machine] (ステートマシンの作成) を選択します。

空白テンプレートを選択します。

コードペインで、ステートマシンJSONを定義する以下を貼り付けます。

Amazon ステートメント言語の詳細については、[State Machine Structure] (ステートマシンの構造) を参照してください。

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

Iterator Resource フィールドを、前に作成した Iterator Lambda 関数ARNの に置き換えます。

Config を選択し、 などのステートマシンの名前を入力しますIterateCount。

タイプ の場合、標準 のデフォルト値を受け入れます。アクセス許可 で、新しいロールの作成 を選択します。

作成を選択し、ロールの作成を確認します。

IterateCount ページで、実行の開始 を選択します。

（オプション) 生成されたデフォルトを上書きするカスタム実行名を入力します。

[実行のスタート] を選択します。

ステートマシンの新しい実行がスタートされ、進行中の実行が表示されます。

実行は、Lambda 関数を使用してカウントを追跡しながら段階的に増分されます。反復ごとに、ステートマシンの ExampleWork 状態で参照されている作業例が実行されます。

カウントがステートマシンの ConfigureCount 状態で設定した数に到達すると、実行が反復を完了して終了します。