基础 本文档描述 Celery 中任务实例和 Canvas 使用的统一 “Calling API”。 API 中定义了一个执行选项的标准集，以及三个方法： 　　- apply_async(args[, kwargs[, ...]]) 发送任务消息 　　 - delay(*args ...

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

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

基础 有多种类型的事件可以触发信号，你可以连接到这些信号，使得在他们触发的时候执行操作。 连接到 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_tasks 异步任务 　　当我们需要批量的去执行一些接口，如测试平台的批量运行测试用例时，如果是同步任务的话，会等待用例一个个执行完毕才有返回结果。当点击运行后，后台直接返回一条信息，由celery服务来运行用例，这就是异步 celery_tasks 工作流 　　平台会通 ...