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 関数はインデックスを増分し、インデックスが count より小さい場合に true を continue に返します。このテストでは、インデックスは既に 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 に置き換えます。

[設定] を選択し、ステートマシンの [名前] (IterateCount など) を入力します。

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

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

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

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

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

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

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

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