Gravtory

Gravtory 是一款专为 Python 开发者设计的生产级持久化工作流引擎，旨在简化复杂任务的管理，确保高可靠性和零基础设施依赖。它通过利用现有数据库，提供原子检查点、Saga补偿、并行执行和分布式工作者等功能，无需额外消息代理，让开发者能够专注于业务逻辑，而非底层运维。

核心功能

Gravtory 的核心在于其 防崩溃 的工作流设计，即使在系统故障或意外中断时，也能通过原子检查点机制自动恢复，避免数据丢失或任务重复。它支持 Saga补偿，用于处理分布式事务中的失败回滚，确保数据一致性。此外，引擎内置 并行执行 和 分布式工作者，可高效处理大规模任务，提升整体性能。

主要特性

• 零基础设施需求：无需部署消息代理或额外服务，直接使用现有数据库（如 PostgreSQL、MySQL 等）作为后端，降低运维成本和复杂性。
• 原子检查点：在工作流执行过程中自动保存状态，确保每次操作都是原子的，防止部分失败导致的数据不一致问题。
• Saga补偿机制：提供内置的补偿逻辑，用于回滚失败的事务步骤，维护分布式系统的可靠性。
• 高性能并行处理：支持多任务并行执行和分布式工作者模式，轻松扩展以应对高负载场景。
• 易于集成：作为纯 Python 库，可无缝集成到现有项目中，快速启动工作流管理。

适用场景

Gravtory 适用于需要高可靠工作流的场景，如电商订单处理、金融交易系统、数据处理流水线或微服务架构中的任务协调。它特别适合中小型团队或初创公司，希望以最小成本实现生产级工作流管理，避免因基础设施问题导致的崩溃风险。