SuperAPI AI 工具集

saga-orchestration

办公与效率

查看项目

更新于 10-16 00:30

技能介绍

用途:为分布式事务和长时运行业务流程提供 Saga 模式实现指导,适用于多服务事务协调、补偿事务、长流程编排、分布式失败处理、订单履约与审批工作流。

主要能力:介绍两种 Saga 类型(协同式 Choreography 与编排式 Orchestration),定义 Saga 执行状态(started、pending、compensating、completed、failed),并提供四类模板:Saga 编排器基类、订单履约 Saga、基于协同的 Saga(OrderChoreographySaga)、带超时的 Saga 编排器(TimeoutSagaOrchestrator)。编排器以事件发布/订阅驱动步骤执行,失败时按逆序触发各步骤的补偿动作。

使用方式:继承 SagaOrchestrator,实现 saga_type 与 define_steps,通过 start 启动流程;业务服务订阅步骤命令并在完成后发布 SagaStepCompleted 或 SagaStepFailed 事件;补偿动作发布 SagaCompensationCompleted。协同式实现则通过事件总线订阅与发布事件串联各服务。

要点与限制:步骤应设计为幂等,补偿逻辑须可靠,建议使用关联 ID 做跨服务追踪并设置超时。资料未提供安装命令、具体语言运行时之外的依赖版本、性能数据、收费与平台支持信息,均暂未提供。