如何构建AWS状态函数以不同自定义负载重复触发同一Lambda

完全可以用简单方式实现，核心就是用Map状态结合参数映射来完成负载构建，不需要复杂的Pass状态嵌套。

具体实现步骤 #

• 拆分列表：通过Map状态的ItemsPath指定要遍历的苹果品种列表，比如$.apple_varieties，这样Map会自动遍历每个品种生成子任务。
• 构建自定义负载：利用Map的Parameters字段，同时引用根输入的商店信息（通过$$.Execution.Input访问整个状态机输入）、当前遍历的苹果品种（$表示当前项），再添加预设的颜色映射。
• 触发Lambda：在Map的Iterator里配置Task状态，把构建好的负载直接传给目标Lambda。

状态机示例配置 #

{
  "Comment": "批量生成苹果负载并触发Lambda",
  "StartAt": "ProcessAppleVarieties",
  "States": {
    "ProcessAppleVarieties": {
      "Type": "Map",
      "ItemsPath": "$.apple_varieties",
      "Parameters": {
        "store_info": "$$.Execution.Input.store_info",
        "apple_variety": "$",
        "color": {
          "Fuji": "red",
          "Gala": "yellow",
          "Granny Smith": "green"
        }.$
      },
      "Iterator": {
        "StartAt": "CallAppleLambda",
        "States": {
          "CallAppleLambda": {
            "Type": "Task",
            "Resource": "arn:aws:lambda:REGION:ACCOUNT_ID:function:YOUR_LAMBDA_FUNCTION",
            "End": true
          }
        }
      },
      "End": true
    }
  }
}

输入输出示例 #

状态机输入

{
  "store_info": {
    "store_id": "NYC_001",
    "store_name": "Big Apple Market"
  },
  "apple_varieties": ["Fuji", "Gala", "Granny Smith"]
}

每个Lambda收到的负载（以Fuji为例）

{
  "store_info": {
    "store_id": "NYC_001",
    "store_name": "Big Apple Market"
  },
  "apple_variety": "Fuji",
  "color": "red"
}

额外说明 #

• 如果颜色映射需要从输入动态获取，可把颜色表放到状态机输入里，修改Parameters中的color字段为"$$.Execution.Input.color_mapping.$"即可。
• 默认Map是并行触发Lambda，若需要按顺序串行执行，给Map状态添加"MaxConcurrency": 1参数。

内容的提问来源于stack exchange，提问作者livsruss