继续作为新执行

打开 Lambda 控制台，然后选择创建函数。

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

在 Author with code snippets (使用代码段创作) 部分中，配置 Lambda 函数，如下所示：

1. 对于 Name (名称)，输入 Iterator。

2. 对于 Runtime (运行时)，选择 Node.js 10.15。

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

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

   注意

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

5. 选择 Create function。

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

   arn:aws-cn:lambda:us-east-1:123456789012:function:Iterator

将以下 Lambda 函数代码复制到 Lambda 控制台中的迭代器 页面的配置部分中。

exports.iterator = 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 作为事件名称。

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

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

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

选择 Create。

在 Lambda 控制台中的迭代器 页面上，确保列出了 TestIterator，然后选择测试。

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

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

打开 Lambda 控制台，然后选择创建函数。

在 Author with code snippets (使用代码段创作) 部分中，配置 Lambda 函数，如下所示：

1. 对于 Name (名称)，输入 Restart。

2. 对于 Runtime (运行时)，选择 Node.js 10.15。

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

4. 在现有角色下，选择包含您之前创建的 IAM 策略的角色。

5. 选择 Create function。

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

   arn:aws-cn:lambda:us-east-1:123456789012:function:Restart

将以下 Lambda 函数代码复制到 Lambda 控制台中的重启 页面的配置部分中。

以下代码可将执行次数的计数递减，并启动状态机的新执行，包括已递减的值。

var aws = require('aws-sdk');
var sfn = new aws.StepFunctions();

exports.restart = function(event, context, callback) {

  let StateMachineArn = event.restart.StateMachineArn;
  event.restart.executionCount -= 1;
  event = JSON.stringify(event);

  let params = {
      input: event,
      stateMachineArn: StateMachineArn
  };

  sfn.startExecution(params, function(err, data) {
      if (err) callback(err);
      else callback(null,event);
  });

}

选择 Save。

在 Step Functions 控制台中，选择 Create a state machine (创建状态机)。

选择 Author with code snippets (使用代码段创作)。对于 Type (类型)，选择 Standard (标准)，然后输入 ContinueAsNew 作为状态机名称。

将以下内容粘贴到 Code 窗格。

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

更新 Restart 和 Iterator 状态中的 Resource 字符串，引用您之前创建的各 Lambda 函数。

选择 Next (下一步)。

创建或输入 IAM 角色：

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

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

在 New execution (新执行) 页面的 Input (输入) 部分，输入 Test1 作为执行名称。然后在 Input (输入) 中输入以下内容。

{
  "restart": {
    "StateMachineArn": "arn:aws-cn:states:us-east-1:123456789012:stateMachine:ContinueAsNew",
    "executionCount": 4
  }
}
        

使用您的 ContinueAsNew 状态机的 ARN 更新 StateMachineArn 字段。

选择 Start Execution (开始执行)。