Mastra工作流重试完整指南3步配置错误处理与自动重试【免费下载链接】mastraMastra is the modern TypeScript framework for AI-powered applications and agents.项目地址: https://gitcode.com/GitHub_Trending/ma/mastra工作流第3步失败就要从头重跑一次API瞬时超时就能让长流程中断。Mastra 工作流重试与错误处理机制让失败的步骤自动重试而不是整个流程推倒重来。本文讲清它的原理、配置方法和观察手段。为什么需要工作流重试三个常见失败场景外部API瞬时超时调用模型或支付接口偶尔返回 5xx 或连接重置。过几秒再试通常就能成功。上游数据未就绪前置服务还在写入当前步骤读到空数据直接报错立即失败其实不划算。资源竞争数据库连接池打满、触发限流。同样的请求稍作延迟即可通过。这三类错误的共同点是“瞬时性”重试几次就能自愈不该让一次抖动打断整个流程。重试原理如何区分可重试错误Mastra 的运行结果对象有四种状态success、failed、suspended、tripwire。只有failed与重试相关——步骤抛出错误后执行器先检查重试次数没耗尽就等待一段时间后重跑该步骤。重试本质上是一个“受限循环”配置分两级级别参数重试次数间隔策略触发条件工作流级retryConfigattempts所有步骤共享默认 0不重试delay毫秒固定间隔默认 0工作流内任意步骤抛错步骤级retries单个步骤专属覆盖工作流级设置复用工作流级delay仅该步骤执行抛错需要注意内置间隔是固定值不提供开箱即用的指数退避策略。想要延迟递增可以配合do-while这类循环控制结构自己实现。对本来就不该重试的错误校验失败、权限不足建议在步骤内捕获后用branch()走降级分支。三步配置 Mastra 工作流重试第一步给整个工作流设默认重试策略。export const testWorkflow createWorkflow({ id: data-pipeline, retryConfig: { attempts: 3, delay: 2000 }, }) .then(step1) .commit();第二步对调用不稳定外部服务的步骤用retries单独提高次数会覆盖工作流级attemptsconst fetchStep createStep({ id: fetch-data, retries: 5, execute: async () { const res await fetch(https://api.example.com/data); if (!res.ok) throw new Error(HTTP ${res.status}); return { data: await res.json() }; }, });第三步挂上回调做集中告警。onFinish在任意结束状态都会触发onError仅在失败时触发。回调里可以发通知、写监控平台回调内抛出的异常只会被记录不会影响工作流结果。如何观察重试与排障路径运行后检查结果对象看result.status判断成败遍历result.steps就能定位哪个步骤是failed并取出该步骤的error。实时观察run.stream()可消费执行流逐步看到每个步骤的输出与统计适合长时间运行的工作流。排障路径出问题时先看onError里的状态与错误信息判断是瞬时错误值得重试还是逻辑错误应修代码。字段细节参考错误处理官方文档执行细节见工作流源码。工作流错误处理配置的常见坑默认以为会重试attempts默认是 0不配置就一次失败直接结束。以为内置指数退避delay是固定间隔想要退避需自己实现别按错误处理配置文档的想象来写。对不可重试错误盲目重试校验失败、4xx 权限错误重试再多次也不会好应先捕获或用branch()走降级。告警里没定位失败步骤onError给的是工作流级错误想知道具体步骤要看steps字段。把回调异常当告警通道onError里抛出的异常只会被记录若你的告警服务本身不可用通知就静默丢失了。重试机制要记住的只有一点让瞬时错误自愈让持续性错误清晰暴露在哪一步、为什么失败。配置时把 attempts 控制在 2~5 次、delay 别设得太小再给不可重试的错误留一条降级出路工作流的可恢复性就有了基本保障。【免费下载链接】mastraMastra is the modern TypeScript framework for AI-powered applications and agents.项目地址: https://gitcode.com/GitHub_Trending/ma/mastra创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考