json - 如何循环 json 输入 - aws 步骤函数/状态机

Question

是否可以在 aws step 函数中创建循环并循环遍历 json 输入数组？

我有一个功能 generateEmails用 n 创建数组对象数量:

{
  "emails": [
    {
      "to": [
        "willow1@aaa.co.uk"
      ]
    },
    {
      "to": [
        "willow2@aaa.co.uk"
      ]
    },    {
      "to": [
        "willow3@aaa.co.uk"
      ]
    }
  ]
}

现在我想调用下一个函数 sendEmail对于 emails 数组中的每个对象，如下所示:

{
  "email": {
    "to": [
      "willow@aaa.co.uk"
    ]
  }
}

步骤功能代码:

{
  "Comment": "A state machine that prepares and sends confirmation email ",
  "StartAt": "generateEmails",
  "States": {
    "generateEmails": {
      "Type": "Task",
      "Resource": "arn:aws:lambda::prepare-confirmation-email",
      "Next": "sendEmail"
    },
    "sendEmail": {
      "Type": "Task",
      "Resource": "arn:aws:lambda::function:template-service",
      "End" : true
    }
  }
}

这有可能实现吗？

谢谢!

Answer 1

正如 Ward 已经建议的那样，昨天 AWS 官方文档已经更新了几乎相同的示例。您需要修改此示例并在每次迭代结束时从原始数组(您 generateEmails lambda 函数的输出)中删除处理过的数据项。

你可以在我的博文中找到简单的例子:AWS Step Functions. How to process arrays

同时对并行数组处理感兴趣的大家可以点赞map-reduce feature在 AWS 论坛上。