被創建。這使得進行簡單的路由任務非常容易。 假如你有兩台服務器,x 和 y 處理常規任務,還有一台服務 ...
基礎 本文檔描述 Celery 中任務實例和 Canvas 使用的統一 Calling API 。 API 中定義了一個執行選項的標准集,以及三個方法: apply async args , kwargs , ... 發送任務消息 delay args, kwargs 發送任務消息的簡寫,不支持執行選項 calling call 直接調用任務對象,意味着任務不會被工作單元執行,而是在當前進程中執行 ...
2018-10-31 22:18 0 785 推薦指數:
被創建。這使得進行簡單的路由任務非常容易。 假如你有兩台服務器,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 ...