【发布时间】:2018-11-16 06:44:02
【问题描述】:
我使用 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装饰器的任务 - 使用
.delay()调用任务的Django Web 服务。
问题是工作人员能够读取 broker_transport_options,并且如我在设置中所述,它在正确的区域中创建了一个具有正确前缀的队列,但是当 Django 忽略这些设置并将任务推送到队列时没有给定的前缀并且不在正确的区域中。
有人知道这里是什么情况吗?
谢谢, 达尔
【问题讨论】:
-
我也面临同样的问题..
标签: django celery amazon-sqs