基礎 本文檔描述 Celery 中任務實例和 Canvas 使用的統一 “Calling API”。 API 中定義了一個執行選項的標准集,以及三個方法: - apply_async(args[, kwargs[, ...]]) 發送任務消息 - delay(*args ...
任務是構建 celery 應用的基礎塊。 任務是可以在任何除可調用對象外的地方創建的一個類。它扮演着雙重角色,它定義了一個任務被調用時會發生什么 發送一個消息 ,以及一個工作單元獲取到消息之后將會做什么。 每個任務都有不同的名稱,發給 celery 的任務消息中會引用這個名稱,工作單元就是根據這個名稱找到正確的執行函數。 任務消息只有在被工作單元確認后才會從隊列中刪除。工作單元會預先保存許多任務消 ...
2018-10-31 22:18 0 2051 推薦指數:
基礎 本文檔描述 Celery 中任務實例和 Canvas 使用的統一 “Calling API”。 API 中定義了一個執行選項的標准集,以及三個方法: - apply_async(args[, kwargs[, ...]]) 發送任務消息 - delay(*args ...
注意: 像主題和扇出之類的路由概念並不對所有傳輸介質都可用,請翻閱”傳輸比較表”。 基礎 自動路由 路由最簡單的方式是使用 task_create_missing_queues 設置(默認啟用)。 使用這個設置,一個還沒有在 task_queues 中定義的有名隊列將會自動 ...
基礎 有多種類型的事件可以觸發信號,你可以連接到這些信號,使得在他們觸發的時候執行操作。 連接到 after_task_publish 信號的示例: from celery.signals import after_task ...
簡介 celery beat 是一個調度器;它以常規的時間間隔開啟任務,任務將會在集群中的可用節點上運行。 默認情況下,入口項是從 beat_schedule 設置中獲取,但是自定義的存儲也可以使用,例如在 SQL 數據庫中存儲入口項。 你必須保證一個調度一次只被一個調度器運行,否則將 ...
啟動工作單元 你可以通過執行以下命令在前台啟動工作單元: $ celery -A proj worker -l info 查看啟動工作單元的可用命令行選項,可以執行: $ celery worker --help 你可以在同一台機器上啟動多個工作單元,只要確保 ...
簡介 Celery 提供了監控和探查celery集群的工具。 這篇文檔描述了一些工具,以及與監控相關的一些特性,例如事件和廣播命令。 工作單元 命令行管理工具(inspect/control) Celery 可以用來探查和管理工作單元節點(以及一定程度上對任務管理)。 列出 ...
這篇文檔描述了可用的配置選項。 如果你使用默認的加載器,你必須創建 celeryconfig.py 模塊並且保證它在python路徑中。 配置文件示例 以下是配置示例,你可以從這個開始。它包括運行一個基本Celery應用的所有基礎設置。 ## Broker settings. ...
celery beat 是一個調度器;它以常規的時間間隔開啟任務,任務將會在集群中的可用節點上運行。 默認情況下,入口項是從 beat_schedule 設置中獲取,但是自定義的存儲也可以使用,例如在 SQL 數據庫中存儲入口項。 你必須保證一個調度一次只被一個調度器運行,否則將會形成重復任務 ...