我可以通过以下方式查看 celery 中的保留任务队列:
from celery.task.control import inspect
len(inspect().reserved().values()[0])
但是,即使我向 celery 发送了 600 个作业,这个队列似乎也很小(大约 8-10 个)。
在 shell 中,我可以看到有 520 个工作等待进入 celery 中的工人保留队列
>> sudo rabbitmqctl list_queues
Listing queues ...
ae20060e09ee49e3bf534141bb0ef921 1
63f1c530ce114f00b9d0ab595eb65c55 1
382e86abce8449e48b0b168fbcf4aebc 1
celeryev.68becb00-9f8f-4252-ab3a-2cd5c12890f6 0
celery 520
0988376d422a4e338bf2d32037c996fc 1
c401d93d38944caa967a147540c4a738 1
d1a78e47d28941749f65282652d973ff 1
ip-10-196-155-73.celery.pidbox 0
84b4d109f44c4e8ba5b549399cc53b30 1
5780425d-d2c7-3036-8be1-4298a51250ff.reply.celery.pidbox 0
8d0c1cd14ebb4fa2b25b565d409580dd 1
a44f22cf759c4e7dbb6fccd673ce1b62 1
77c17e95689740b68d9ca84b3065a2ce 1
但是,我希望能够从 python 中知道队列当前(520)和最大容量。
或者,一旦我填满队列,rabbitMQ 会阻塞吗?如果是这样,我如何找出最大容量,以及如何更改它?
另外,我怎么知道队列中还有多少任务?