Celery 2.0 Documentation

语言	格式	评分
英语	.pdf	3
摘要
《Celery 2.0 Documentation》介绍了Celery 2.0版本的主要功能和改进。Celery是一个基于分布式消息传递的任务队列/作业队列，支持异步和同步任务执行。文档详细说明了新功能，包括对Python 2.7的支持、任务序列化改进、新的远程控制命令（如stats和dump active）、实验性的持久 revoke 支持，以及对Django的分离处理。此外，文档还涵盖了Celery的安装、配置和使用，包括对RabbitMQ、Redis等消息代理的支持。
AI总结
### Celery 2.0 版本更新总结 #### 1. 版本发布信息 - 发布日期: 2010年7月2日 - 主要版本: 2.0.0 #### 2. 新功能与改进 - Python 2.7 支持: 测试通过并支持Python 2.7。 - 任务序列化: 通过`Task.__reduce__`改进了任务的序列化和反序列化能力。 - 远程控制命令: - `stats`: 显示 worker 的运行信息，包括任务执行统计和池进程状态。 - `dump active`: 列出当前正在执行的任务，默认使用 `repr` 处理不可序列化的参数，支持 `safe=True` 选项。 - 持久化撤销支持: 实验性支持任务撤销的持久化，通过 `--statedb` 参数启用。 - 队列设置优化: `CELERY_ROUTES` 和 `CELERY_QUEUES` 的优先级调整，`CELERY_ROUTES` 的值优先于 `CELERY_QUEUES`。 #### 3. 功能特性 - 消息队列: 支持 RabbitMQ、Stomp、Redis 和 SQL 数据库。 - 分布式任务: 支持多机部署，任务并行执行。 - 任务调度: 支持定时任务（类似 cron）、指定时间或倒计时执行。 - 结果存储: 支持数据库、MongoDB、Redis 等多种结果存储后端。 - 远程控制: 支持任务撤销、状态查询和实时监控。 - 错误处理: 任务失败后可配置重试次数和延迟，支持邮件通知。 #### 4. 弃用与移除 - 移除的设置: - `CELERY_AMQP_CONSUMER_QUEUES` 替换为 `CELERY_QUEUES`。 - `CELERY_AMQP_EXCHANGE` 替换为 `CELERY_DEFAULT_EXCHANGE`。 - 其他旧的 AMQP 相关设置被移除。 - Loader 定义: 需包含类名，如 `celery.loaders.default.Loader`。 - 任务集运行方式: 建议使用 `TaskSet.apply_async()` 替代 `TaskSet.run()`。 - 模块移除: `celery.task.rest` 替换为 `celery.task.http`。 #### 5. 兼容性与升级 - Django 集成: 移出 Django 支持，需安装独立包 `Django-celery` 并更新 `INSTALLED_APPS` 配置。 - CeleryLoader 配置: 使用 `Django` 加载器需设置环境变量 `CELERY_LOADER = "django"`。 #### 6. 其他改进 - 日志与监控: 支持实时事件订阅和 Web 监控。 - 错误处理: 支持自定义错误白名单，改进了任务失败邮件通知和终端重缩故障处理。 #### 7. 文档与资源 - 官方文档: [http://celeryproject.org/docs](http://celeryproject.org/docs) - 源码仓库: [http://github.com/ask/celery](http://github.com/ask/celery) #### 8. 总结 Celery 2.0 引入了多项重要改进，提升了任务的可靠性和可扩展性，同时优化了对分布式系统的支持。建议用户仔细阅读升级指南，确保平滑过渡到新版本。