Celery Worker为何自动创建新SQS队列而非指定队列？

问题场景 #

在Django集成Celery，通过ECS部署Worker时，已配置以下Celery参数：

CELERY_BROKER_URL = "sqs://"
CELERY_ACCEPT_CONTENT = ["application/json"]
CELERY_TASK_SERIALIZER = "json"
CELERY_RESULT_SERIALIZER = "json"
CELERY_IMPORTS = "app.tasks"
CELERY_BROKER_TRANSPORT_OPTIONS = {"region": "us-west-2"}
CELERY_TASK_DEFAULT_QUEUE = "staging.fifo"

ECS任务已赋予Worker完整SQS权限，但容器启动后，Worker未使用指定的staging.fifo队列，反而自动创建默认的celery队列。

核心原因及修复方案 #

1. 未显式定义FIFO队列特性 #

Celery的SQS传输对FIFO队列需要明确配置队列类型，仅设置CELERY_TASK_DEFAULT_QUEUE无法让Celery识别这是一个FIFO队列。需通过CELERY_QUEUES定义队列属性：

from kombu import Queue

CELERY_QUEUES = (
    Queue(
        "staging.fifo",
        queue_type="fifo",
        is_fifo=True,
    ),
)

该配置会强制Celery使用指定的FIFO队列，避免创建默认队列。

2. Worker启动命令未指定监听队列 #

默认情况下，Celery Worker会监听名为celery的队列，即使配置了CELERY_TASK_DEFAULT_QUEUE，若启动命令未指定目标队列，Worker仍会创建并监听默认队列。需在ECS任务的启动命令中添加队列指定参数：

celery -A your_django_app worker -Q staging.fifo --loglevel=info

替换your_django_app为实际的Django项目名称。

3. CELERY_IMPORTS格式错误 #

当前配置中CELERY_IMPORTS为字符串类型，Celery要求该参数必须是列表格式，修正后：

CELERY_IMPORTS = ["app.tasks"]

虽然此问题不直接导致队列异常，但错误格式可能影响任务加载，进而引发Worker行为偏差。

4. 补充FIFO队列传输配置 #

针对SQS FIFO队列，建议在CELERY_BROKER_TRANSPORT_OPTIONS中补充必要参数，确保队列交互正常：

CELERY_BROKER_TRANSPORT_OPTIONS = {
    "region": "us-west-2",
    "visibility_timeout": 3600,  # 根据业务需求调整超时时间
}

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