基礎 本文檔描述 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 工作流 　　平台會通 ...