Cần tây - Lập trình danh sách công nhân

Question

Làm cách nào để lập trình, sử dụng mã Python, liệt kê các nhân viên hiện tại và các phiên bản celery.worker.consumer.Consumer tương ứng của họ?

Answer 1

Nếu bạn thêm --events khi bắt đầu. Bạn có thể kiểm tra mô-đun này cho người lao động kiểm tra hiện tại và vv http://docs.celeryproject.org/en/latest/userguide/monitoring.html

Answer 2

Bạn có thể sử dụng celery.control.inspect để kiểm tra người lao động chạy:

>>> import celery 
>>> celery.current_app.control.inspect().ping() 
{u'celery@host': {u'ok': u'pong'}} 

Answer 3

Câu trả lời ngắn:

your_celery_app.control.inspect().stats().keys()

Nói chung rằng stats() từ điển cung cấp rất nhiều thông tin. Dưới đây là một giá trị ví dụ:

{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}},