如何在AWS CDK中为Step Function添加全局错误捕获？

问题描述 #

我正在使用AWS CDK构建一个主要由Lambda链式调用组成的Step Function，代码结构如下：

lambda_1
      .next(lambda_2)
      .next(lambda_3)
      .next(lambda_4)
      .next(lambda_5)

当任意一个Lambda抛出已处理或未处理的错误时，我需要通过另一个Lambda记录错误并执行清理操作。目前我可以通过Step-Function-Failed事件触发该Lambda，但为了可视性，更希望将日志记录作为Step Function内的步骤。我查阅了相关文档，但未找到可全局调用addCatch方法的位置，请问是否存在为Step Function添加全局错误捕获的方法？

可行解决方案 #

AWS Step Functions没有原生的全局错误捕获API，但可以通过以下两种高效方式实现需求：

1. 封装辅助函数批量添加错误处理 #

编写一个通用函数，为每个Lambda任务节点统一配置addCatch，避免重复编写代码：

const addErrorHandler = (task: sfn.TaskStateBase) => {
  return task.addCatch(errorHandlingLambda, {
    errors: ['States.ALL'], // 捕获所有类型的错误
    resultPath: '$.errorDetails' // 将错误信息存储到指定的状态路径中
  });
};

// 重构链式调用逻辑
addErrorHandler(lambda_1)
  .next(addErrorHandler(lambda_2))
  .next(addErrorHandler(lambda_3))
  .next(addErrorHandler(lambda_4))
  .next(addErrorHandler(lambda_5));

这种方式能让每个Lambda步骤的错误都流转到同一个错误处理Lambda，同时在Step Function控制台中清晰展示错误处理流程。

2. 用父状态包裹主流程实现全局捕获 #

如果后续流程有扩展需求，可以将整个Lambda链放入Parallel状态（或根据场景选择Map状态），再给这个父状态添加一次Catch配置即可：

// 定义原有的Lambda链式流程
const mainWorkflow = lambda_1
  .next(lambda_2)
  .next(lambda_3)
  .next(lambda_4)
  .next(lambda_5);

// 用Parallel状态包裹主流程并添加全局错误捕获
const workflowWrapper = new sfn.Parallel(this, 'MainWorkflowWrapper')
  .branch(mainWorkflow)
  .addCatch(errorHandlingLambda, {
    errors: ['States.ALL'],
    resultPath: '$.errorDetails'
  });

// 创建StateMachine时以包裹后的状态作为起始
new sfn.StateMachine(this, 'MyStateMachine', {
  definitionBody: sfn.DefinitionBody.fromChainable(workflowWrapper)
});

这种方式只需配置一次错误处理，后续主流程扩展时无需重复操作，适合复杂或迭代中的工作流。

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