使用Celery 5.5.0与RabbitMQ 4.1.1，如何避免celery_delayed_0-27队列创建？

问题根源 #

Celery 5.5.0的原生延迟任务机制默认会创建28个分片延迟队列（celery_delayed_0至celery_delayed_27），目的是通过分片提升延迟任务的处理效率。当你切换到RabbitMQ的Quorum队列后，这些分片队列会被自动创建为Quorum类型，但如果你的Worker没有配置监听这些队列，就会触发“无消费者”的告警。

可行解决方案 #

1. 禁用原生延迟交付 #

如果不需要依赖RabbitMQ的原生延迟功能，直接关闭该特性即可阻止这些队列创建：
在Celery配置文件中添加：

CELERY_BROKER_TRANSPORT_OPTIONS = {
    'native_deliver': False  # 关闭原生延迟交付
}

关闭后，Celery会回到传统的Beat轮询方式处理延迟任务，不会再生成celery_delayed系列队列。注意此时需要确保Celery Beat服务正常运行，否则延迟任务无法被触发。

2. 让Worker监听所有延迟分片队列 #

如果要保留RabbitMQ原生延迟功能，必须让Worker消费这些分片队列：

• 配置文件方式：

from celery import Queue

CELERY_QUEUES = (
    Queue('celery', routing_key='celery'),
    # 批量添加所有28个延迟分片队列
    *[Queue(f'celery_delayed_{i}', routing_key=f'celery_delayed_{i}') for i in range(28)]
)

• 命令行启动方式：

celery -A your_app worker -Q celery,celery_delayed_0,celery_delayed_1,...,celery_delayed_27

Worker监听这些队列后，就不会再触发无消费者的告警。

3. 自定义延迟队列分片数量 #

如果觉得28个队列太多，可以通过配置减少分片数：

CELERY_BROKER_TRANSPORT_OPTIONS = {
    'delayed_queue_partitions': 4  # 按需设置分片数量，比如4个
}

调整后只会创建对应数量的celery_delayed队列，同时记得让Worker监听这些调整后的队列。

额外提示 #

修改配置后，务必重启所有Celery Worker和Beat服务，确保新配置生效。

内容的提问来源于stack exchange，提问作者Olha Ushkalenko