python - How to list the queued items in celery? -


i have django project on ubuntu ec2 node, have been using set asynchronous using celery.

i following http://michal.karzynski.pl/blog/2014/05/18/setting-up-an-asynchronous-task-queue-for-django-using-celery-redis/ along docs.

i've been able basic task working @ command line, using:

(env1)ubuntu@ip-172-31-22-65:~/projects/tp$ celery --app=myproject.celery:app worker --loglevel=info 

i realized, have bunch of tasks in queue, had not executed:

[2015-03-28 16:49:05,916: warning/mainprocess] restoring 4 unacknowledged message(s). (env1)ubuntu@ip-172-31-22-65:~/projects/tp$ celery -a tp purge warning: remove tasks queue: celery.          there no undo operation!  (to skip prompt use -f option)  sure want delete tasks (yes/no)? yes purged 81 messages 1 known task queue. 

how list of queued items command line?

if want scheduled tasks,

celery inspect scheduled 

to find active queues

celery inspect active_queues 

for status

celery inspect stats 

for commands

celery inspect 

if want explicitily.since using redis queue.then

redis-cli  >keys * #find keys 

then find out related celery

>llen key # think gives length of list 

Comments

Popular posts from this blog

google chrome - Developer tools - How to inspect the elements which are added momentarily (by JQuery)? -

angularjs - Showing an empty as first option in select tag -

php - Cloud9 cloud IDE and CakePHP -