AWS Step Functions Map状态下记录任务成败的实现问题

核心思路 #

Step Functions中父作用域变量是不可变的，无法在子状态（如Map内部）直接修改。因此需通过以下方式实现需求：

• 用MaxConcurrency:1 + StopOnError:true实现Map单并发迭代，遇失败立即停止
• 借助Map的ResultPath收集成功项，通过Catch机制捕获失败项信息
• 后续状态汇总成功/失败结果，而非在Map内部修改父变量

针对问题的具体解决方案 #

1. 父作用域数组无法在Map内更新 #

放弃直接修改父变量，改用状态输出传递：

• 初始化阶段定义空的成功列表、失败项变量
• Map状态通过ResultPath将成功处理的项写入成功列表变量
• 失败时通过Catch将失败信息写入失败项变量
• 最终在汇总状态中组合这些变量得到结果

2. Map无法捕获失败项 #

给Map状态添加Catch规则，结合StopOnError:true：

• StopOnError:true确保Map遇到第一个失败就停止迭代
• Catch捕获所有错误类型（States.ALL），将失败项的上下文和错误信息传递到后续状态
• 通过ResultPath指定失败信息的存储路径，避免覆盖原有成功数据

3. 布尔标记仍遇变量更新限制 #

同样利用状态输出传递标记，而非修改父变量：

• 在单条项处理状态中，成功时返回{"Status":"Success", "Item": <项内容>}
• 失败时抛出错误或返回{"Status":"Failure", "Item": <项内容>}
• Map的成功输出会包含所有成功标记的项，失败时通过Catch捕获失败标记的项

4. $states.context.Map.Item.Name不存在 #

确认Map迭代的数据源类型：

• 若迭代数组，使用$states.context.Map.Item.Value获取当前项值，$states.context.Map.Item.Index获取数组索引
• 仅当迭代键值对对象集合时，$states.context.Map.Item.Name才会存在（对应键名）

完整状态机示例 #

{
  "Comment": "单并发Map失败即停+成功失败项记录",
  "StartAt": "Initialize",
  "States": {
    "Initialize": {
      "Type": "Pass",
      "Parameters": {
        "ItemsToProcess.$": "$.Items",
        "SuccessList": [],
        "FailureItem": null
      },
      "Next": "ProcessItems"
    },
    "ProcessItems": {
      "Type": "Map",
      "ItemProcessor": {
        "StartAt": "ProcessSingleItem",
        "States": {
          "ProcessSingleItem": {
            "Type": "Task",
            "Resource": "arn:aws:lambda:REGION:ACCOUNT_ID:function:YourProcessingLambda",
            "Parameters": {
              "Item.$": "$"
            },
            "End": true
          }
        }
      },
      "ItemsPath": "$.ItemsToProcess",
      "MaxConcurrency": 1,
      "StopOnError": true,
      "ResultPath": "$.SuccessList",
      "Catch": [
        {
          "ErrorEquals": ["States.ALL"],
          "Next": "RecordFailure",
          "ResultPath": "$.FailureItem"
        }
      ],
      "Next": "FinalizeResult"
    },
    "RecordFailure": {
      "Type": "Pass",
      "Parameters": {
        "Item.$": "$.Cause",
        "Error.$": "$.Error"
      },
      "Next": "FinalizeResult"
    },
    "FinalizeResult": {
      "Type": "Pass",
      "Parameters": {
        "CombinedResult": [
          {"Success.$": "$.SuccessList[0]"},
          {"Failure.$": "$.FailureItem.Item"}
        ]
      },
      "End": true
    }
  }
}

示例说明 #

• Initialize：初始化待处理数组、空成功列表和失败项变量
• ProcessItems：单并发Map，遇失败立即停止；成功项写入SuccessList，失败触发Catch进入RecordFailure
• RecordFailure：格式化失败项信息（可根据需求调整）
• FinalizeResult：将成功项和失败项组合为用户期望的输出格式

测试输出验证 #

输入：{"Items": [1,2,3]}（假设处理第二项2时失败）
输出：

{
  "CombinedResult": [
    {"Success": 1},
    {"Failure": 2}
  ]
}

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