python - 如何列出 celery 中排队的物品？

我在Ubuntu EC2节点上有一个Django项目，我一直使用该项目使用Celery设置异步。

我正在关注http://michal.karzynski.pl/blog/2014/05/18/setting-up-an-asynchronous-task-queue-for-django-using-celery-redis/和文档。

我已经能够使用以下命令在命令行上执行基本任务:

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

我刚刚意识到，队列中有一堆尚未执行的任务:

[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: This will remove all tasks from queue: celery.
         There is no undo for this operation!

(to skip this prompt use the -f option)

Are you sure you want to delete all tasks (yes/NO)? yes
Purged 81 messages from 1 known task queue.

如何从命令行获取排队项目的列表？

最佳答案

如果您要获取所有计划任务，

celery inspect scheduled

查找所有事件队列

celery inspect active_queues

地位

celery inspect stats

对于所有命令

celery inspect

如果您想显式地获取它，因为您使用redis作为队列。

redis-cli

>KEYS * #find all keys

然后找出与celery相关的内容

>LLEN KEY # i think it gives length of list

关于python - 如何列出 celery 中排队的物品？，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/29319889/