使用Celery(RabbitMQ,Django)检索队列长度

Question

我在django项目中使用Celery,我的经纪人是RabbitMQ,我想检索队列的长度.我查看了Celery的代码,但没有找到工具来做到这一点.我在stackoverflow上发现了这个问题(从客户端检查RabbitMQ队列大小),但我觉得它并不令人满意.

一切都是在芹菜中设置的,所以应该有某种神奇的方法来检索我想要的东西,而不指定通道/连接.

有没有人对这个问题有任何想法？

谢谢 !

Answer 1

您可以使用inspect模块检查 celery 中的工作人员。这是指南。

另外RabbitMQ还有一些命令行命令。