Celery之監控與管理

celery兩種監控工具： 命令列實用工具和web實時監控工具flower

一。命令列工具

1）進入shell環境

python

3.7.1 (default, jun 12

2020, 10:34:40

)[gcc

4.8.5

20150623 (red hat 4.8.5-39

)] on linux

type

"help

", "

", "

credits

" or "

license

"for

more information.

(interactiveconsole)

》 locals().keys()

dict_keys([

'', '

celery

', '

task

', '

chord

', '

group

', '

chain

', '

chunks

', '

xmap

', '

xstarmap

', '

subtask

', '

signature

', '

low', '

add', '

fall

', '

__builtins__'])

0x7fce228aac88>還可以執行任務

addtaskb.delay()

2)status 在集群中列出啟用的節點

celery -a celery_task.celery status

celery@vm_0_6_centos: ok
celery@vm_0_6_centos: ok

3)result 列出任務的執行結果

celery -a celery_task.celery result -t tasks.taska

4）purse 從所有配置的任務佇列清除任務訊息

celery -a celery_task.celery purge

指定清除的佇列
celery -a celery_task.celery purge -q default
, tasks_a
或排除指定任務佇列
celery -a celery_task.celery purge -x tasks_b
注意：此命令將從配置的任務佇列中清除所有的資訊。不可撤銷，永久清除

5）inspect active 列出啟用的任務

celery -a celery_task.celery inspect active

- empty -

-> celery@vm_0_6_centos: ok

- empty -

6）inspect scheduled 列出計畫任務

celery -a celery_task.celery inspect scheduled

7）inspect registered 列出以註冊的任務

celery -a celery_task.celery inspect registered

->celery@vm_0_6_centos: ok
*celery_task.tasks.add
*celery_task.tasks.fall
*celery_task.tasks.low
->celery@vm_0_6_centos: ok
*celery_task.tasks.add
*celery_task.tasks.fall
* celery_task.tasks.low

8）inspect stats 列出worker的統計資訊

celery -a celery_task.celery inspect stats

9）inspect query_task 通過id獲取任務的資訊

celery -a celery_task.celery inspect query_task

可以查詢多個

celery -a celery_task.celery inspect query_task id1 id2 ...

10） control enable_events/disable_events. 啟用/禁用事件

celery -a celery_task.celery control enable_events

celery -a celery_task.celery control disable_events

11)migrate 將任務有乙個中間人轉移到另乙個中間人上，試驗性命令，確保對資料進行備份

celery -a celery_task.celery migrate redis://

localhost amqp:
//localhost

二。web實時監控工具flower

1）安裝

pip install flower

2)啟動

預設埠http:

//localhost:5555 也支援指定埠

中間人url指定

可結合supervisor進行服務部署

celery程式設計 supervisor監控

二 使用配置檔案 啟動celery命令 三 定時任務 四 flower監控中介軟體 五 supervisor管理程序 主角 celery 配角 redis 或者 rabbitmq linux pip install reids celerywindows pip install redis even...

使用celery之怎麼讓celery跑起來

celery 官網幫助文件 前言自從發了上次的文章使用celery之深入celery配置,有一些再問我怎麼讓celery跑起來.其實說來也是,celery在新手眼裡真的是比較重量級,不好懂,今天先讓他跑起來吧 本文大部分 和使用方法都可以在celery官網看到 我想要的效果 我想實現乙個定時任務,每...

Python之celery的簡介與使用

celery是乙個基於分布式訊息傳輸的非同步任務佇列，它專注於實時處理，同時也支援任務排程。它的執行單元為任務 task 利用多執行緒，如eventlet，gevent等，它們能被併發地執行在單個或多個職程伺服器 worker servers 上。任務能非同步執行 後台執行 或同步執行 等待任務完成...