Hatchet

用于后台任务、AI Agent 和持久化工作流的编排引擎

Hatchet Cloud · 文档 · 官网 · Issues

什么是 Hatchet？

Hatchet 是一个用于大规模编排后台任务、AI Agent 和持久化工作流的平台。它支持使用 Python、TypeScript、Go 和 Ruby 编写的应用程序，既可以通过 Hatchet Cloud 作为服务使用，也可以自托管部署。Hatchet 为任务队列、自动重试、持久化、实时监控、告警和日志记录提供了完整的平台支持。

快速入门

使用 Hatchet 最快的方法是注册 Hatchet Cloud 进行试用！即使你计划自托管，我们也建议先尝试 Cloud，以便了解完整部署后的 Hatchet 平台是什么样子。

若要在本地运行 Hatchet，最快捷的方法是安装 Hatchet CLI（支持 MacOS、Linux 或 WSL）—— 请注意，这需要本地安装 Docker：

curl -fsSL https://install.hatchet.run/install.sh | bash
hatchet --version
hatchet server start

要查看有关自托管和使用云服务的完整文档，请参阅文档。

什么时候应该使用 Hatchet？

你可以使用 Hatchet 来运行后台任务、AI Agent 或其他类型的长时工作流。它被设计为一个功能完备的解决方案，适用于对正确性、可靠性、水平扩展性和可观测性有严格要求的系统。从技术角度来看，它与其他解决方案的不同之处在于，它使用 Postgres 作为任务运行时和可观测性系统的持久化层，这使得它非常易于自托管。

关于你可以使用 Hatchet 构建的端到端工作流示例，请查看我们的实战手册 (cookbooks)。

Hatchet 功能特性

后台任务

• 后台任务：Hatchet 支持定义为简单函数的单次后台任务。它同时支持“即发即忘”和“订阅式等待结果”的任务模式。
• 重试机制：灵活且可配置的任务重试策略，支持可选的指数退避 (exponential backoff)。
• Cron 任务 和 定时任务：用于在未来某个时间点调度任务。
• 任务路由：基于严格条件（如 Worker 标签）进行路由，或使用 Worker 亲和性 (worker affinity) 进行更复杂的加权调度。
• 基于事件的触发 和 监听器：用于构建事件驱动的高度分布式系统。
• 基于 Webhook 的触发：方便从上游数据源触发 Hatchet 任务。

任务编排与工作流

• 持久化任务：用于构建容错性强、可从故障中轻松恢复的长时工作流。
• DAG (有向无环图)：用于构建数据流水线和简单工作流。请参阅我们关于选择持久化任务还是 DAG 的指南。
• 复杂的暂停/恢复条件：利用持久化睡眠 (durable sleep)、事件等待 (event waits) 或两者结合来实现。

扩展性

• 优先级：确保关键任务可以在对延迟不敏感的任务（如后台补录作业）之前运行。
• 速率限制：用于应对第三方 API 的限制，甚至可以通过动态速率限制来强制执行每个用户的速率配额。
• 公平调度：保证资源在不同任务队列间合理分配。