Celery & Rabbitmq Commands

README

Run celery_status.sh in a shell, this will display (real time) the current running celery processes.

Try to kill celery using the "rake celery:kill" task and watch to see if they go away, if they do not, you may have to resort to using "kill -9" on specific pids. 

Use the "rake rabbitmq:qs" to see how many requests are in each queue in rabbitmq. If there are 60+ in the error queue run the "clear_rabbitmq_queue.py" file to clear them out.

celery_status.sh

while [ 1 ]; do
	clear
	ps aux | grep celery | grep -v grep
	sleep 3
done

clear_rabbitmq_queue.py

from amqplib import client_0_8 as amqp
conn = amqp.Connection(host="localhost:5672")
conn = conn.channel()
conn.queue_purge("error")