如何阻止芹菜推入已满的 rabbitmq 队列

问题描述 投票:0回答:0

我有一个用 Kombu 定义的队列,如下所示

from kombu import Queue

Queue("myname", "exchange", max_length=10, x_overflow='reject-publish')

我的期望是拒绝所有传入的消息,并且 rabbitmq 管理中的发布计数仍然为 0,但是我发现,该数字不是 0,而是我设置 celery beat 发布的速率。为什么会这样?

如果队列已满,我怎么告诉 celery beat 不创建任务?

python rabbitmq celery
© www.soinside.com 2019 - 2024. All rights reserved.