如何以編程方式使用Python代碼列出當前工人及其相應的celery.worker.consumer.Consumer
實例?芹菜 - 以編程方式列出工作人員
12
A
回答
1
如果您在啓動時將添加--events
鍵。您可以檢查此模塊檢查當前工人等http://docs.celeryproject.org/en/latest/userguide/monitoring.html
21
您可以使用celery.control.inspect檢查正在運行的工人:
>>> import celery
>>> celery.current_app.control.inspect().ping()
{u'[email protected]': {u'ok': u'pong'}}
7
簡短的回答:
your_celery_app.control.inspect().stats().keys()
普遍認爲stats()
字典給出了很多信息。下面是一個例子值:
{u'broker': {u'alternates': [],
u'connect_timeout': 4,
u'heartbeat': 0,
u'hostname': u'mypcisdabom',
u'insist': False,
u'login_method': u'AMQPLAIN',
u'port': 5672,
u'ssl': False,
u'transport': u'amqp',
u'transport_options': {},
u'uri_prefix': None,
u'userid': u'celeryabuser',
u'virtual_host': u'celeryvhost'},
u'clock': u'182309',
u'pid': 1660,
u'pool': {u'max-concurrency': 1,
u'max-tasks-per-child': u'N/A',
u'processes': [2496],
u'put-guarded-by-semaphore': True,
u'timeouts': [0, 0],
u'writes': u'N/A'},
u'prefetch_count': 4,
u'rusage': u'N/A',
u'total': {u'mymodule.my_func': 8}},
相關問題
- 1. 芹菜/ Django - 如何以編程方式查看工人狀態
- 2. 芹菜+ sqlalchemy以何種方式嚴重處理多名工人?
- 3. 無法讓芹菜工人工作
- 4. 芹菜工作流程
- 5. 芹菜 - 工人退出exitcode1的燒瓶
- 6. 運行芹菜工作人員在單元測試
- 7. 芹菜工作人員的活動Django設置文件
- 8. 芹菜 - 工作人員不接受新任務
- 9. 由芹菜工作人員執行任意函數
- 10. 芹菜工作人員和命令行參數
- 11. (芹菜):在特定的工作人員中運行任務?
- 12. Django芹菜:傳遞請求對象到工作人員
- 13. 芹菜廣播返回所有工作人員的結果
- 14. 芹菜:CELERYD_CONCURRENCY和工人
- 15. 工人在Django芹菜
- 16. 芹菜工人丟失
- 17. 芹菜 - 爲不同的隊列設置不同數量的工作人員
- 18. 芹菜工作人員是否按特定順序檢查隊列?
- 19. 如何確定芹菜工作人員在運行時消耗哪些隊列?
- 20. 芹菜關閉從task_success處理程序不工作的工人
- 21. 芹菜:無法用新用戶名連接遠程工作人員
- 22. 在FLASK應用程序中同時運行芹菜節拍和工作人員
- 23. 芹菜:以編程方式將任務排隊到特定的隊列?
- 24. 芹菜和扇出 - 確保每個工人獨特的隊列?
- 25. 如何以編程方式禁用Chrome開發人員工具中的JavaScript?
- 26. RuntimeError使用時Theano在芹菜芹菜工人共享變量
- 27. 以編程方式列出類中的成員變量名稱
- 28. 芹菜製作芹菜MQL
- 29. 停止監督員不會阻止芹菜工人
- 30. 如何以編程方式列出我的LinkedIn聯繫人?
漂亮的一個,這個我可以構建一個REST API,詢問工人均達到或如果他們墜毀並通知用戶 – psychok7
https://github.com/psychok7/django-芹菜檢查 – psychok7