Làm thế nào tôi có thể xem các nhiệm vụ enqueued trong RabbitMQ?

Question

Tôi đang sử dụng RabbitMQ làm người môi giới thông điệp của tôi và công nhân của tôi là nhiệm vụ Celery. Tôi đang cố gắng để chẩn đoán một vấn đề mà tôi đang enqueue nhiệm vụ để RabbitMQ nhưng Celery không chọn sau đó lên.

Có cách nào tôi có thể kiểm tra những nhiệm vụ được đặt trong RabbitMQ không? Tôi muốn xem ngày và thời gian khi họ được enqueued, bất kỳ ETA được chỉ định, các đối số và tên nhiệm vụ.

Tôi không thể tìm thấy thông tin này trong tài liệu - có thể tôi đã bỏ qua nó - và hy vọng rằng một số bạn có thể biết một cách dễ dàng để kiểm tra hàng đợi công việc. Cảm ơn.

Answer 1

Bạn có thể sử dụng Hoa để theo dõi tác vụ trong thời gian thực.

https://github.com/mher/flower

Check-out cũng rabbitmqclt lệnh mà kiểm tra tình trạng server RabbitMQ:

http://www.rabbitmq.com/man/rabbitmqctl.1.man.html

rabbitmqctl list_queues 

Answer 2

Ngoài ra một số nhiệm vụ cần tây để giám sát hàng đợi:

http://docs.celeryproject.org/en/latest/userguide/monitoring.html

Kiểm tra các lệnh này:

#shows status of all worker nodes 
celery status 
#List active tasks 
celery inspect active 
#Show worker statistics (call counts etc.) 
celery inspect stats  

Answer 3

Chừng nào các management plugin là enabled, một số tùy ý các thông điệp có thể được tiêu thụ từ hàng đợi và tùy chọn requeued:

rabbitmqadmin get queue=queue_name requeue=true count=100