被创建。这使得进行简单的路由任务非常容易。 假如你有两台服务器，x 和 y 处理常规任务，还有一台服务 ...

简介 celery beat 是一个调度器；它以常规的时间间隔开启任务，任务将会在集群中的可用节点上运行。 默认情况下，入口项是从 beat_schedule 设置中获取，但是自定义的存储也可以使用，例如在 SQL 数据库中存储入口项。 你必须保证一个调度一次只被一个调度器运行，否则将 ...

任务是构建 celery 应用的基础块。 任务是可以在任何除可调用对象外的地方创建的一个类。它扮演着双重角色，它定义了一个任务被调用时会发生什么（发送一个消息），以及一个工作单元获取到消息之后将会做什么。 每个任务都有不同的名称，发给 celery 的任务消息中会引用这个名称，工作单 ...

基础 有多种类型的事件可以触发信号，你可以连接到这些信号，使得在他们触发的时候执行操作。 连接到 after_task_publish 信号的示例： from celery.signals import after_task_publish ...

启动工作单元 你可以通过执行以下命令在前台启动工作单元： $ celery -A proj worker -l info 查看启动工作单元的可用命令行选项，可以执行： $ celery worker --help 你可以在同一台机器上启动多个工作单元，只要确保 ...

简介 Celery 提供了监控和探查celery集群的工具。 这篇文档描述了一些工具，以及与监控相关的一些特性，例如事件和广播命令。 工作单元 命令行管理工具（inspect/control） Celery 可以用来探查和管理工作单元节点（以及一定程度上对任务管理）。 列出 ...

这篇文档描述了可用的配置选项。 如果你使用默认的加载器，你必须创建 celeryconfig.py 模块并且保证它在python路径中。 配置文件示例 以下是配置示例，你可以从这个开始。它包括运行一个基本Celery应用的所有基础设置。 ## Broker settings. ...

celery —— 任务调用方式 实际上 delay 只是 apply_async 的快捷方式，二者作用相同，只是 apply_async 可以进行更多的任务属性设置，比如 callbacks/errbacks 正常回调与错误回调、执行超时、重试、重试时间等等 celery\app ...