Celery sqs 尝试连接到 amqp：无法连接到 amqp://guest:**@127.0.0.1:5672//答案

【问题标题】：Celery sqs tries to connect to amqp: Cannot connect to amqp://guest:**@127.0.0.1:5672//Celery sqs 尝试连接到 amqp：无法连接到 amqp://guest:**@127.0.0.1:5672//
【发布时间】：2020-12-30 11:51:40
【问题描述】：

我想将 Celery 与 SQS 一起使用。但是，连接错误是amqp://guest:**@127.0.0.1:5672//。
我的设置有什么问题？

celery[sqs]         ==4.4.7  
kombu               ==4.6.11  
billiard            ==3.6.3.0

broker_url = 'sqs://%s:%s@' % (safequote(AWS_ACCESS_KEY_ID), safequote(AWS_SECRET_ACCESS_KEY))
broker_transport_options = {
    'region': 'ap-northeast-1',
    'visibility_timeout': 3600,
    'polling_interval': 1,
    'queue_name_prefix': 'pre-',
}

result_backend = None
accept_content = ['pickle']
beat_schedule = {
    "add": {
        "task": "tests.tasks.insert_task",
        "schedule": crontab(minute=0, hour='*', day_of_week='0,5,6'),
    },
}

【问题讨论】：

标签： django celery

【解决方案1】：

似乎您的 celery 连接选项有误。 Celery 正在尝试连接到 rabbitmq。我建议将broker_transport 设置为sqs，看看它是否仍然有效。

【讨论】：