我使用Django 2.0和芹菜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忽略这些设置并将任务推送到没有给定前缀的队列中,而不是在正确的区域中时。
有人知道这是怎么回事吗?
谢谢你,达尔
发布于 2018-06-19 16:34:31
确保正确设置了芹菜conf的命名空间设置。
https://stackoverflow.com/questions/50722791
复制