Я использую Django 2.0 с Celery 4 и SQS в качестве брокера.
Я использовал следующие CELERY_BROKER_TRANSPORT_OPTIONS:
{'queue_name_prefix': 'qa-', 'region': 'eu-west-1'}
У меня есть:
- Выделенный рабочий, работающий с использованием
celery -A <app_name> worker -Q <queue_name>
- Задача с
@shared_task
декоратором - Веб-служба Django, которая вызывает задачу с
.delay()
.
Проблема в том, что работник может прочитать broker_transport_options, и он создал очередь с правильным префиксом в правильном регионе, как я указал в настройках, но когда Django игнорирует эти настройки и переносит задачу в очередьбез указанного префикса и не в нужном регионе.
Кто-нибудь знает, что здесь происходит?
Спасибо, Дар