在 Step Function 内循环

我试图在循环中调用步骤函数中的几个步骤，但我无法弄清楚我需要如何执行此操作。这是我现在所拥有的：我需要添加另一个 lambda 函数（GetReviews），然后它将循环调用 CreateReview、SendNotification。我该怎么做呢？ 我指的是“使用 Lambda 迭代循环 https://docs.aws.amazon.com/step-functions/latest/dg/tutorial-create-iterate-pattern-section.html”文件，这表明这是可能的。

阶跃函数定义：

{
  "Comment": "Scheduling Engine",
  "StartAt": "CreateReview",
  "States": {
    "CreateReview": {
      "Type": "Task",
      "Resource": "arn:aws:lambda:us-west-2:.........:function:CreateReview",
      "Next": "CreateNotification",
      "InputPath": "$",
      "ResultPath": "$.CreateReviewResult",
      "OutputPath": "$"      
    },
    "CreateNotification": {
      "Type": "Task",
      "Resource": "arn:aws:lambda:us-west-2:.........:function:CreateNotification",
      "InputPath": "$",
      "ResultPath": "$.CreateNotificationResult",
      "OutputPath": "$",
      "End": true
    }
  }
}

我对这个答案做出了贡献，因为我使用了一种稍微不同的方法来能够在步骤函数内部循环，而不必依赖 lambda 来递增。如果将来有人需要通用解决方案，这可以是一个很好的参考。 这是带有代码的示例：

{
"Comment": "A description of my state machine",
"StartAt": "InitVariables",
"States": {
    "InitVariables": {
        "Type": "Pass",
        "Parameters": {
            "index": 0,
            "incrementor": 1,
            "ArrayLength.$": "States.ArrayLength($.inputArray)"
        },
        "ResultPath": "$.iterator",
        "Next": "LoopChoice"
    },
    "LoopChoice": {
        "Type": "Choice",
        "Choices": [
            {
                "Variable": "$.iterator.ArrayLength",
                "NumericGreaterThanPath": "$.iterator.index",
                "Next": "IncrementVariable"
            }
        ],
        "Default": "End"
    },
    "IncrementVariable": {
        "Type": "Pass",
        "Parameters": {
            "index.$": "States.MathAdd($.iterator.index, $.iterator.incrementor)",
            "incrementor": 1,
            "ArrayLength.$": "$.iterator.ArrayLength"
        },
        "ResultPath": "$.iterator",
        "Next": "LoopChoice"
    },
    "End": {
        "Type": "Pass",
        "End": true
    }
} }

这是循环的基础，我使用States.MathAdd($.iterator.index, $.iterator.incrementor)用于添加两个值的内部函数，在本例中，使用 initVariables 状态中定义的增量来增加索引。并获取我想要循环的数组的长度。您还可以使用内部函数来获取数组长度，States.ArrayLength("$.path.to.array")。该数组在输入中传递。 要获取数组的值，我们可以使用内部函数，States.ArrayGetItem($.inputArray, $.iterator.index)。 所有自定义逻辑都应该放在loopChoice状态和IncrementVariable状态之间。

希望这对将来的人有帮助。