Celery仅注册task1-queue，其余队列未注册问题排查

1. Worker启动命令未指定所有目标队列 #

Celery worker默认只会监听默认队列（通常是celery），如果启动时只指定了task1-queue，那worker只会注册并监听这个队列，其他队列的任务根本不会被处理。

正确的启动命令需要把所有队列用逗号分隔：

celery -A your_fastapi_app worker -Q task1-queue,task2-queue,task3-queue --loglevel=info

2. Task Routes配置存在错误 #

检查你的Celery配置中task_routes的规则是否正确匹配了task2、task3：

• 字典式配置要确保任务的完整路径写对：

  task_routes = {
      "your_app.tasks.task1": {"queue": "task1-queue"},
      "your_app.tasks.task2": {"queue": "task2-queue"},
      "your_app.tasks.task3": {"queue": "task3-queue"},
  }
  

• 如果用正则匹配，要确认表达式能覆盖task2、task3，比如别把规则写成只匹配task1开头的任务。

3. 链式任务的Signature队列指定错误 #

链式任务中每个子任务都必须明确指定对应队列，否则会默认发到worker当前监听的队列（这里只有task1-queue），但如果worker没监听其他队列，后续任务会一直积压。

正确的链式任务写法：

from celery import chain, signature

# 每个任务都要指定对应队列
chain(
    task1.s(),
    signature(task2.s(), queue="task2-queue"),
    signature(task3.s(), queue="task3-queue")
).apply_async()

还要检查队列名拼写是否和配置一致，别出现大小写或者拼写错误（比如把task2-queue写成task2_queue）。

4. Celery配置未正确加载 #

确认你的FastAPI项目中Celery实例正确加载了包含task_routes的配置。比如创建Celery实例时是否传入了正确的配置：

from celery import Celery

celery = Celery("your_app")
# 加载配置文件
celery.config_from_object("your_app.config")

如果配置文件路径错误，或者task_routes没写到生效的配置里，task2、task3的路由规则根本不会起作用。

5. 任务模块未被Celery自动发现 #

如果task2、task3所在的模块没被Celery实例纳入自动发现范围，worker不知道这些任务的存在，自然不会注册对应的队列。

解决方法：

• 创建Celery实例时通过include参数指定所有任务模块：

  celery = Celery(
      "your_app",
      include=["your_app.tasks.task1", "your_app.tasks.task2", "your_app.tasks.task3"]
  )
  

• 或者启动worker时用--include参数手动指定：

  celery -A your_app worker -Q task1-queue,task2-queue,task3-queue --include=your_app.tasks.task2,your_app.tasks.task3
  

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