You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

如何在状态机中捕获Lambda异常并规避ResultSelector错误?

问题解决步骤

1. 先修复Catch块的语法错误

你的状态机Catch块里重复定义了ErrorEquals字段,这是无效的JSON结构,会导致状态机无法正确识别错误捕获规则。需要合并成一个错误类型数组:

"Catch": [
  {
    "ErrorEquals": [
      "Lambda.FunctionError", // 匹配Lambda抛出的自定义异常
      "States.Runtime",       // 匹配状态机运行时错误(比如JSONPath找不到)
      "States.ALL"            // 兜底匹配所有其他错误
    ],
    "ResultPath": "$.error",
    "Next": "error state"
  }
]

2. 解决ResultSelector在异常时的报错问题

当Lambda抛出异常时,任务输出是错误对象(包含Error和Cause字段),而非正常的Payload结构,此时ResultSelector里的$.Payload.tables必然找不到,触发Runtime错误。有两种可行方案:

方案一:给JSONPath添加默认值

利用JSONPath的条件运算符,当目标路径不存在时返回默认值(比如空数组),避免报错:

"ResultSelector": {
  "tables.$": "$.Payload.tables || []"
}

这样即使Lambda抛出异常,tables会被设为空数组,同时Catch块会捕获错误并进入error state。

方案二:拆分任务与结果处理逻辑

移除Lambda任务的ResultSelector,新增一个Pass状态专门处理正常结果的选择,异常时直接跳过该状态:

// 原Lambda任务修改为
{
  "Type": "Task",
  "Resource": "arn:aws:lambda:xxx:xxx:function:your-function", // 替换为你的Lambda ARN
  "ResultPath": "$.export_tables_temp",
  "Catch": [
    {
      "ErrorEquals": ["Lambda.FunctionError", "States.ALL"],
      "ResultPath": "$.error",
      "Next": "error state"
    }
  ],
  "Next": "Process Lambda Result"
},
// 新增处理结果的Pass状态
"Process Lambda Result": {
  "Type": "Pass",
  "ResultSelector": {
    "tables.$": "$.export_tables_temp.Payload.tables"
  },
  "ResultPath": "$.export_tables",
  "Next": "Export Tables"
},
"error state": {
  "Type": "Fail"
},
"Export Tables": {
  "Type": "Map",
  "End": true,
  "ItemsPath": "$.export.tables",
  "Parameters": {
    "product.$": "$.product",
    "table_export_def.$": "$$.Map.Item.Value"
  }
}

这种方式更清晰,异常时直接进入错误状态,不会执行结果处理步骤,从根源避免JSONPath报错。

额外说明

  • Lambda抛出的自定义异常,在状态机中对应的错误类型是Lambda.FunctionError,必须加入ErrorEquals才能被捕获。
  • States.ALL是兜底规则,确保所有未匹配的错误都能被捕获。

内容的提问来源于stack exchange,提问作者Madhu

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.08.18 18:25:34