继续作为新执行

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

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

在使用代码段创作部分中，配置 Lambda 函数，如下所示：

1. 对于名称，输入 Iterator。

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

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

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

   注意

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

5. 选择创建函数。

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

   arn:aws: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 (创建)。

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

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

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

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

在使用代码段创作部分中，配置 Lambda 函数，如下所示：

1. 对于名称，输入 Restart。

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

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

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

5. 选择创建函数。

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

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

将以下 Lambda 函数代码复制到配置的 部分Restart (重新启动)页面中的 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” 控制台上，选择创建状态机。

选择 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: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:lambda:us-east-1:123456789012:function:Restart",
          "Next": "Done"
        },
        "Done": {
            "Type": "Pass",
            "End": true 
        }
    }
}

更新Resource string in the Restart和Iterator状态引用您之前创建的各 Lambda 函数。

选择 Next。

创建或输入 IAM 角色：

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

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

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

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

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

选择 Start Execution (开始执行)。