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
Post a Comment