1、安裝celery的redis依賴:pip install -u "celery[redis]"
使用unix套接字連線:redis+socket:///path/to/redis.sock
virtual_host引數新增到url:redis+socker:///path/to/redis.sock?virtual_host=db_number
3、可見性超時時間定義了等待職程在訊息分派到其他職程之前確認收到任務的秒數:
5、廣播資訊預設對所有虛擬主機可見。你需要設定乙個傳輸選項來給訊息加上字首,這樣訊息只會被
活動的虛擬主機收到:
7、如果任務沒有在 可見性超時 內確認接收,任務會被重新委派給另乙個職程並執行。
時,任務將迴圈重新執行。
所以你需要增大可見性超時時間,以符合你計畫使用的最長預計到達時間。
注意 celery 會在職程關閉的時候重新分派訊息,所以較長的可見性超時時間只會造成在斷電或強制終止
職程之後「丟失」任務重新委派的延遲。
8、redis 在某些情況會從資料庫中驅除鍵。如果遇到了類似這樣的錯誤:
inconsistencyerror: probably the key ('_kombu.binding.celery') has been
removed from the redis database.
配置redis-server的timeout引數為0
二 Celery基本命令和配置
from celery import celery def add x,y return x y 2 執行程式 celery a tasks worker loglevel info 3 檢視命令列引數列表 celery worker help celery help 4 用delay 方法呼叫任務...
celery配置與基本使用
定義celery例項,需要的引數,1,例項名,2,任務發布位置,3,結果儲存位置 mycelery broker redis 任務存放的地方 backend redis 結果存放的地方 defadd x,y return x y 1.啟動celery 1.1 單程序啟動celery celery a...
celery配置與基本使用
定義celery例項,需要的引數,1,例項名,2,任務發布位置,3,結果儲存位置 mycelery broker redis 任務存放的地方 backend redis 結果存放的地方 defadd x,y return x y 測試時一般使用併發數高的 1.啟動celery 1.1 單程序啟動ce...