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

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

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

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

注意： 　　 像主题和扇出之类的路由概念并不对所有传输介质都可用，请翻阅”传输比较表”。 基础 自动路由 路由最简单的方式是使用 task_create_missing_queues 设 ...

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

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

Celery用户指引–Workers启动、重启 1.启动worker 通过下面的命令在前台启动worker $ celery -A proj worker -l info 1 通过下面的命令查看worker命令的所有相关选项 ...