1

我可以通过以下方式查看 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 会阻塞吗?如果是这样,我如何找出最大容量,以及如何更改它?

另外,我怎么知道队列中还有多少任务?

4

0 回答 0