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

Question

我想将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'),
},
}

Answer 1

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