任務管理:

說明: 如上為執行任務後的標準輸出,transport為訊息代理,concurrency為預設程序池程序數,當所有子程序處於忙碌狀態時必須等待空閒子程序處理,如果是IO密集型可嘗試使用Eventlet/Gevent協程,具體可參考http://docs.jinkan.org/docs/celery/userguide/concurrency/index.html#concurrency,result為結果儲存,queue為所有的佇列以及交換機資訊列表

# 啟動節點

celery multi start notify -A work.app -c 4 -l info --pidfile=notify.pid --logfile=notify.log

# 關閉節點

celery multi stop  notify -A work.app -c 4 -l info --pidfile=notify.pid --logfile=notify.log

celery multi stopwait  notify -A work.app -c 4 -l info --pidfile=notify.pid --logfile=notify.log

celery multi kill  notify -A work.app -c 4 -l info --pidfile=notify.pid --logfile=notify.log

# 重啟節點

celery multi restart notify -A work.app -c 4 -l info --pidfile=notify.pid --logfile=notify.log

# 檢視節點

celery multi names notify -A work.app -c 4 -l info --pidfile=notify.pid --logfile=notify.log

celery multi show notify -A work.app -c 4 -l info --pidfile=notify.pid --logfile=notify.log

說明: Celery提供了一個multi子名稱,可以很方便的管理Celery應用的啟動(notify表示應用的唯一標識,-A表示應用的入口檔案,-c表示預設工作程序下將啟動的子程序數,--pidfile表示程序檔案,--logfile表示日誌檔案)/關閉(stop表示非同步停止應用,stopwait表示同步等待停止應用,kill表示終止應用,但需要注意的是必須指定--pidfile和--logfile)/重啟(restart表示重啟應用,但需要注意的是預設multi並不記憶之前啟動引數,所以需要和啟動引數一樣)

擴充套件: 如果想要跟蹤不同子程序的日誌可直接在--pidfile和--logfile中使用上面的格式化引數,如celery multi start notify -A work.app -c 4 -l info --pidfile=notify%I.pid --logfile=notify%I.log,則會在當前執行目錄下生成不同程序的程序ID以及日誌檔案,但是當你關閉和重啟的時候就不那麼方便了~

任務排程:

celery beat --help

任務跟蹤:

celery result --help

celery -A work.app inspect --help

線上控制:

celery amqp --help

celery -A work.app control --help

線上節點:

celery -A work.app status