Celery 2.0 Documentation

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

摘要

文档介绍了Celery 2.0，一个开源的异步任务队列/作业队列，基于分布式消息传递，支持实时操作和调度。任务可在一个或多个worker服务器上异步或同步执行。Celery支持多种消息代理，如RabbitMQ、Redis和数据库，并提供与Django的集成。文档还涵盖了任务的基本使用、执行、日志记录、重试机制、选项设置等，以及worker的启动、停止、重启和配置。其目标是通过提供灵活的任务处理和分布式执行解决方案，优化任务调度和管理。

AI总结

### Celery 2.0 Documentation 总结

#### 1. 项目概述
- **Celery** 是一个开源的异步任务队列/作业队列，基于分布式消息传递。它专注于实时操作，但也支持计划任务。
- 任务可以在一个或多个 worker 服务器上异步或同步执行。
- Celery 支持多种消息代理（如 RabbitMQ、Redis 和数据库）和 Webhooks，适用于多种语言，包括 Python、Django 和 Ruby on Rails。

#### 2. 核心功能与特点
- **任务（Tasks）**：任务是 Celery 的执行单元，支持异步和同步执行。
- **消息代理（Broker）**：推荐 RabbitMQ，但也支持 Redis 和数据库。
- **Webhooks**：允许与其他语言集成。
- **分布式任务队列**：任务可以在多个 worker 上并发执行。
- **计划任务**：支持周期性任务。
- **结果后端**：支持存储任务结果，后端可选如 Redis、数据库等。

#### 3. 文档结构与主要内容
- **用户指南**：
- 任务的基本操作（默认关键字参数、日志记录、重试机制、任务选项）。
- Worker 使用指南（启动、停止、重启 worker，设置并发、时间限制等）。
- 任务集合、子任务和回调（支持任务的分组执行和 HTTP 回调）。
- 任务路由与 AMQP 选项。
- **内部机制**：
- Worker 结构、数据结构、任务消息协议、事件。
- 模块索引，详细说明各组件的功能。
- **入门指南**：
- 安装与配置（支持 RabbitMQ、Redis 和数据库）。
- 快速入门教程，如“创建点击计数器”。
- **教程**：
- 使用 Redis/数据库 作为消息队列的示例。
- Django 与 Celery 的集成。
- **API 参考**：
- 详细的 API 接口说明，包括任务装饰器、任务集、执行任务、结果处理等。
- **重要变更**：
- 2.0 版本的删除和替换，例如 CELERY_AMQP_CONSUMER_QUEUES 替换为 CELERY_QUEUES。
-PopulationTaskSet.run() 替换为 TaskSet.apply_async()。
- **社区支持**：
- 提供 bug 跟踪、Wiki 和贡献指南。

#### 4. 安装与配置
- **安装**：支持从 PyPI、GitHub 源码等方式安装。
- **配置**：包括并发设置、任务结果后端、数据库后端、 Redis 后端等。

#### 5. 使用示例
- **快速入门**：创建任务、启动 worker、配置周期性任务。
- **Django 集成**：通过 django-celery 包实现。

#### 总结
Celery 2.0 是一款功能强大、灵活的分布式任务队列工具，支持多种消息代理和后端存储，适合异步处理和实时任务执行。文档详细介绍了其使用、配置、内部机制和 API 接口，同时提供了丰富的教程和社区支持资源，帮助开发者快速上手和深入掌握。