使用 Lambda 迭代循环

登录到Lambda 控制台，然后选择创建函数。

在创建函数部分中，选择从头开始创作。

在基本信息部分中，配置 Lambda 函数，如下所示：

1. 在函数名称中，输入 Iterator。

2. 适用于运行时中，选择Node.js 12.x。

3. 对于 Role (角色)，选择 Use an existing role (使用现有角色)。

4. 适用于现有角色中，选择您在创建 Step Functions 状态Machine使用 Lambda教程。

   注意

   如果您创建的 IAM 角色未显示在列表中，该角色可能仍需要几分钟才能传播到 Lambda。

5. 选择创建函数。

   创建 Lambda 函数后，记下函数位于页面右上角的 Amazon 资源名称 (ARN)，如所示。

   arn:aws:lambda:us-east-1:123456789012:function: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 += step
 
  callback(null, {
    index,
    step,
    count,
    continue: index < count
  })
}

此代码接受 count、index 和 step 的输入值。它将递增index的值step并返回这些值及布尔值continue。如果 index 小于 count，continue 的值为 true。

选择 Save。

在配置测试事件对话框中，选择创建新测试事件，然后输入TestIterator对于 来说为Event name (事件名称)。

使用以下内容替换示例数据。

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

这些值模拟在迭代期间来自状态机的内容。Lambda 函数将递增索引并将返回continue作为true。当索引不小于count，它返回continue作为false。在此测试中，索引已增加到 5。结果应增加index到6并将continue到true。

选择 Create (创建)。

在存储库的迭代器页面，请确保TestIterator，然后选择测试。

测试结果将显示在页面顶部。选择详细信息并查看结果。

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

登录到Step Functions 控制台，然后选择创建状态机。

在 Define state machine (定义状态机) 页面上，选择 Author with code snippets (使用代码段创作)。适用于类型中，选择标准。对于名称，输入 IterateCount。

选择 Next (下一步)。

创建或输入 IAM 角色：

以下代码描述了一个具有以下状态的状态机。

在代码窗格中，使用您的 Amazon 资源名称 (ARN) 添加以下状态机器定义。您之前创建的 Lambda 函数。

{
    "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状态，以便它引用您之前创建的 Lambda 函数。有关亚马逊语言的更多信息，请参阅状态机结构。

使用可视工作流程窗格中检查您的 Amazon State 语言代码是否正确描述了状态机。

此图显示了以前状态机器代码中表达的逻辑。

如果您未看到该图表，请在 Visual Workflow 窗格中选择“”。

选择 Next。

创建或输入 IAM 角色：

选择 Create state machine (创建状态机)。

在 IterateCount 页面上，选择 New execution (新执行)。

(可选) 为了帮助识别您的执行，您可以在输入执行名称。如果未输入 ID，Step Functions 将自动生成一个唯一 ID。

选择 Start Execution (开始执行)。

此时将开始状态机的新执行，并显示正在运行的执行。

执行逐步递增，使用您的 Lambda 函数跟踪计数。在每次迭代时，它都会执行在状态机中处于 ExampleWork 状态引用的示例工作。

(可选) 在 Execution Details 部分中，选择 Info 选项卡以查看 Execution Status 以及 Started 和 Closed 时间戳。

当计数达到ConfigureCount状态，执行退出迭代并结束。