rabbitmqctl
正确报告数千个排队任务:
$ sudo rabbitmqctl -q list_queues name messages messages_ready messages_unacknowledged
default 13142 13126 16
然而芹菜报告:
>>> len(app.control.inspect().active()['celery@default'])
4
>>> len(app.control.inspect().scheduled()['celery@default'])
1
>>> len(app.control.inspect().reserved()['celery@default'])
16
>>> len(app.control.inspect().revoked()['celery@default'])
0
正确数量(数千)的任务似乎出现在 中,但我真的很想知道 python 中未完成的队列任务app.control.inspect().stats()['celery@default']['total']
的正确数量,而等人似乎只报告了 16 个左右——也许有一个限制?active()
没有使用特权子进程调用rabbitmqctl
,我怎样才能从 python 中获取完整的排队任务计数,最好是通过celery
(顺便说一下,这个服务器目前使用的是 Celery 3.1.8)