簡介 Celery 提供了監控和探查celery集群的工具。 這篇文檔描述了一些工具,以及與監控相關的一些特性,例如事件和廣播命令。 工作單元 命令行管理工具(inspect/control) Celery 可以用來探查和管理工作單元節點(以及一定程度上對任務管理)。 列出 ...
啟動工作單元 你可以通過執行以下命令在前台啟動工作單元: celery A proj worker l info 查看啟動工作單元的可用命令行選項,可以執行: celery worker help 你可以在同一台機器上啟動多個工作單元,只要確保給每個獨立的工作單元使用 hostname 參數聲明一個節點名稱。 celery A proj worker loglevel INFO concurren ...
2018-10-31 22:18 0 1593 推薦指數:
簡介 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命令的所有相關選項 ...