我有一个用 Kombu 定义的队列,如下所示
from kombu import Queue Queue("myname", "exchange", max_length=10, x_overflow='reject-publish')
我的期望是拒绝所有传入的消息,并且 rabbitmq 管理中的发布计数仍然为 0,但是我发现,该数字不是 0,而是我设置 celery beat 发布的速率。为什么会这样?
如果队列已满,我怎么告诉 celery beat 不创建任务?