Celery v4.0.1 Documentation

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

摘要

文档介绍了Celery 4.0.1版本的新功能、改进和变更，包括支持新后端如Redis、RPC、Cassandra等，优化任务执行和调度特性，如任务自动重试装饰器，改进了Beat调度器和事件处理机制，并新增了对Sentinel的支持。此外，文档还提到了对旧版本的兼容性更改、废弃的功能以及将在未来版本中移除的模块。文档还提供了安装指南和使用Celery进行任务调度的基本步骤。

AI总结

以下是对《Celery v4.0.1 Documentation》的中文总结，重点突出核心观点和关键信息，保持语言简洁明了：

---

** Celery 4.0.1 文档总结 **

### 新功能与改进
1. **任务（Tasks）**
- 支持任务自动重试装饰器。
- 优化了任务替换（`Task.replace`）功能。
- 支持远程任务追踪（Remote Task Tracebacks）。
- 提供新的任务路由器 API。
- 引入了 Canvas 重构（Canvas Refactor）。

2. **结果后端（Result Backends）**
- RPC 结果后端已成熟。
- Redis 结果后端优化。
- 新增了 Riak、CouchDB、Consul、Cassandra 和 Elasticsearch 等结果后端支持。
-.Supports 文件系统结果后端。

3. **周期性任务（Periodic Tasks）**
- 提供了新的 API 用于配置周期性任务。
- 优化了 Beat 的实现，支持基于日出、日落、黎明和黄昏的任务调度。

4. **其他改进**
- 事件批处理功能。
-Prefork 池改进：子进程日志记录、默认调度策略为 `-Ofair`、限制子进程内存大小、每个子进程单独日志文件。
- 协议更新： поддержка RabbitMQ 优先级队列、分离读写代理 URL 配置、支持 Apache Qpid 传输官方支持 Amazon SQS。
- Redis 支持 Sentinel。

---

### 不兼容的变更
- **Prefork**：在任务中调用 `result.get()` 或加入结果将引发 `RuntimeError`（之前只发出警告）。
- **模块变更**：
- `celery.worker.consumer` 现为包而非模块。
- `celery.worker.job` 重命名为 `celery.worker.request`。
- Beat 的 `Scheduler.Publisher` 重命名为 `Scheduler.Producer`。

---

### 废弃与移除
- **即将在版本 5.0 移除的内容**：
- 旧任务 API（`celery.decorators` 模块）将被移除，需迁移至 `celery.task`。
-部屋 Task 模块、某些设置（如 `BROKER` 和 `REDIS` 结果后端设置）将被移除。
- `Task_sent` 信号和 `Result` 设置将被移除。

- **版本 4.0 的重要说明**：
- 放弃支持 Python 2.6。
- 最后一个支持 Python 2 的版本。
- 取消了某些功能的默认支持（如 Pickle）。

---

### 核心功能亮点
1. **分布式任务队列**：
- 支持 RabbitMQ、Redis、Amazon SQS 等消息代理。
- 可在单机、多机或跨数据中心运行。

2. **高可用性**：
- 工作者和客户端在连接丢失或故障时自动重试。
- 支持主主或主从复制。

3. **高性能**：
- 单进程可每分钟处理数百万任务，时延低至毫秒级（使用 RabbitMQ 和优化配置）。

4. **高扩展性**：
- 支持自定义池实现、序列化器、日志、调度器等。

---

### 安装与升级说明
- **安装要求**：
- 支持 CPython 2.6、2.7 和 3.3，以及 PyPy。
- 不支持 Microsoft Windows。

- **升级说明**：
- 升级前需阅读重要说明。
- 配置文件需根据新设置名称进行调整。

---

如需了解更多细节，可参考原文档或官方文档。