Wie kann ich die eingereihten Aufgaben in RabbitMQ anzeigen?

Question

Ich benutze RabbitMQ als meine Nachrichten Broker und meine Arbeiter sind Sellerie Aufgaben. Ich versuche, ein Problem zu diagnostizieren, bei dem ich Aufgaben an RabbitMQ in die Warteschlange stelle, aber Sellerie greift dann nicht auf.

Kann ich überprüfen, welche Aufgaben in RabbitMQ eingereiht sind? Ich möchte das Datum und die Uhrzeit sehen, wenn sie in die Warteschlange gestellt werden, eine ETA angegeben wird, die Argumente und der Name der Aufgabe.

Ich konnte diese Informationen in den Dokumenten nicht finden - vielleicht habe ich es übersehen - und hoffte, dass einige von Ihnen eine einfache Möglichkeit kennen, die Aufgabenwarteschlange zu untersuchen. Vielen Dank.

Answer 1

Mit Flower können Sie Aufgaben in Echtzeit überwachen.

https://github.com/mher/flower

Schauen Sie sich auch rabbitmqclt Befehl, RabbitMQ Serverstatus überprüft:

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

rabbitmqctl list_queues 

Answer 2

Auch einige Sellerie Aufgaben, die Warteschlange zu überwachen:

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

Sehen Sie sich diese Befehle:

#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

Solange die management pluginenabled ist, eine beliebige Anzahl von Nachrichten von der Warteschlange verarbeitet werden und gegebenenfalls requeued:

rabbitmqadmin get queue=queue_name requeue=true count=100