Сельдерей 4 + Django 2.0 - CELERY_BROKER_TRANSPORT_OPTIONS игнорируется - PullRequest
0 голосов
/ 06 июня 2018

Я использую Django 2.0 с Celery 4 и SQS в качестве брокера.

Я использовал следующие CELERY_BROKER_TRANSPORT_OPTIONS:

{'queue_name_prefix': 'qa-', 'region': 'eu-west-1'}

У меня есть:

  1. Выделенный рабочий, работающий с использованием celery -A <app_name> worker -Q <queue_name>
  2. Задача с @shared_task декоратором
  3. Веб-служба Django, которая вызывает задачу с .delay().

Проблема в том, что работник может прочитать broker_transport_options, и он создал очередь с правильным префиксом в правильном регионе, как я указал в настройках, но когда Django игнорирует эти настройки и переносит задачу в очередьбез указанного префикса и не в нужном регионе.

Кто-нибудь знает, что здесь происходит?

Спасибо, Дар

1 Ответ

0 голосов
/ 20 июня 2018

Убедитесь, что настройки пространства имен для вашего Celery conf установлены правильно

...