如何通过Step Function回调模式将SKU数组替换为对应product_id？

使用场景 #

遍历输入JSON中的SKU数组，通过每个SKU发起GET请求获取对应的product_id，最终按原顺序将数组中的SKU替换为对应的product_id。

Step Function实现步骤 #

• 接收输入的JSON数据
• 通过映射任务遍历SKU数组，使用回调返回模式将每个SKU的查询请求排入API队列，等待队列返回对应的product_id
• 收集所有回调返回的product_id，按原SKU顺序生成新数组并构建目标JSON结构
• 将生成的新对象传入后续业务流程使用

输入输出示例 #

输入示例 #

{
  "data": {
      "product": {
          "configurable_product_links": [
              "SKU1",
              "SKU2",
              "SKU3",
              "SKU4"
          ]
      }
  }
}

输出示例 #

{
  "data": {
      "product": {
          "configurable_product_links": [
              "product_id_1",
              "product_id_2",
              "product_id_3",
              "product_id_4"
          ]
      }
  }
}

回调模式核心实现说明 #

在Step Functions的映射任务中配置回调任务，每个SKU对应的任务会向API处理队列发送查询请求后进入等待状态，直到队列完成SKU到product_id的转换并返回结果。所有回调任务完成后，Step Functions会自动按原SKU的顺序收集product_id，替换原JSON中的configurable_product_links数组，最终输出目标结构。

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