我已经覆盖了 celery 默认队列。下面是提到的设置。

设置

BROKER_URL = "amqp://managedbrokerurl/username/"
CELERY_DEFAULT_QUEUE = 'project.env.default'
CELERY_ROUTES = {"app1.tasks.push_api_task": {"queue": "project.env.priority_queue"}}

工人

python manage.py celery worker -n env_worker -Q project.env.default
python manage.py celery worker -n env_worker -Q project.env.priority_queue 

根据配置，我期待除app1.tasks.push_api_task应进入队列之外的所有任务project.env.default。但是发生了一个奇怪的问题，例如任务将进入project.env.default队列以及celery队列（如果没有被覆盖，这是默认值）。

我检查了我们的代码库，没有任何地方使用celery队列来发布任务。

如果你们遇到过同样的问题，请帮助。