Celery 1.0 Documentation

• 语言: 英语
• 格式: .pdf
• 来源: docs.celeryq.dev

摘要

本文档是Celery 1.0.6稳定版的官方文档。Celery是一个基于分布式消息传递的任务队列/作业队列，专注于实时操作并支持调度。执行单元称为任务，可在一个或多个工作服务器上并发执行，支持异步（后台）或同步（等待完成）执行。Celery已用于生产环境处理每日数百万任务。最初为Django创建，现在可用于任何Python项目，并可通过webhooks与其他语言协作。推荐消息代理为RabbitMQ，也支持Redis和数据库。文档概述了架构：代理将任务推送到工作服务器，工作服务器是运行celeryd的网络机器，可根据负载使用一台或多台机器。任务结果可存储供后续检索（称为“墓碑”）。通过广播队列，可远程撤销任务或设置任务类型的速率限制。文档还包含任务定义、配置、API参考、内部模块参考及版本历史。

AI总结

Celery 1.0.6 是一个基于分布式消息传递的任务/作业队列系统，支持实时操作与定时调度。任务可在单台或多台工作服务器上并发执行，支持异步（后台）或同步（等待结果）模式。它最初为 Django 设计，现在可用于任何 Python 项目，也可通过 Webhooks 与其他语言交互。

核心架构：消息代理（Broker）将任务推送到运行 `celeryd` 的工作服务器。推荐使用 RabbitMQ 作为消息代理，同时也支持 Redis 和数据库。任务结果可存储以供后续检索（称为“墓碑”）。系统支持通过广播队列远程撤销任务或设置任务类型的速率限制。

任务定义：任务可封装为继承 `Task` 类的类，或使用 `@task` 装饰器便捷地将函数转化为任务。任务支持默认关键字参数。

重要更新和修复（包含数据、案例）：
* **0.8.4**：弃用 `--detach` 参数，建议使用 `start-stop-daemon` 或 `supervisord`；任务重试时不再发送错误邮件。
* **0.8.1**：启用 AMQP QoS（服务质量）机制，工作节点将按自身处理能力接收消息，提升稳定性。
* **0.3.20**：`apply_async` 新增 `countdown` 和 `eta` 参数，支持延迟执行；支持 Windows 运行；新增统计功能用于性能监控。
* **0.1.8**：引入 `TaskSet`，支持执行一组子任务并查询完成进度。
* **0.1.7**：支持数据库存储任务元数据；可通过 HTTP 检查任务是否完成。
* **0.1.6**：`celeryd` 会断开连接后自动重连。

配置与API：文档提供了详细的API参考（任务装饰器、执行、结果等）和配置项说明，包括队列、交换机、路由键、连接超时等。同时列出了1.2版本中将要移除的旧设置名称及其替代项。

许可证：采用 New BSD License。