使用 Lambda 函数继续执行新操作

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

在创建函数页面上，选择从 Scratch 开始创作。

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

1. 对于 Function name（函数名称），请输入 Iterator。

2. 对于运行时，选择Node.js 16.x 16.x.

3. 保留页面上的所有默认选项，然后选择创建函数.

   创建 Lambda 函数时，请在页面的右上角记下其亚马逊资源名称 (ARN)，例如：

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

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

exports.handler = function iterator (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 时，它会将 continue 返回为 false。在此测试中，索引已增加到 5。结果应该增加index到6并设置continue到true.

选择Create（创建）。

在迭代器请务必在您的 Lambda 控制台中打开页面TestIterator已列出，然后选择测试.

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

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

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

在创建函数页面上，选择从 Scratch 开始创作。

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

1. 对于 Function name（函数名称），请输入 Restart。

2. 对于运行时，选择Node.js 16.x 16.x.

保留页面上的所有默认选项，然后选择创建函数.

创建 Lambda 函数时，请在页面的右上角记下其亚马逊资源名称 (ARN)，例如：

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

将以下 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);
  });

}

选择部署来部署代码。

在Step Functions ct，选择创建状态机.

将以下代码粘贴到Definition窗格。

{
    "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字符串在Restart和Iterator状态以引用您之前创建的相应的 Lambda 函数。

选择 Next（下一步）。

在指定详细信息页面上，为状态机输入名称。例如，ContinueAsNew。

保留页面上所有其他选项的默认选择，然后选择创建状态机.

将此状态机的亚马逊资源名称 (ARN) 保存在文本文件中。您需要在向 Lambda 函数提供权限的同时提供 ARN 才能开始执行新的 Step Functions。

在ContinueAsNew页面，选择开始执行.

这些区域有：开始执行对话框出现。

（可选）要识别您的执行，可以在中为其指定一个名称名称盒子。默认情况下，Step Functions 会自动生成一个唯一的执行名称。

在输入部分，在开始执行对话框中，输入以下内容作为执行输入：

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

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

选择 Start Execution (开始执行)。