Celery sqs 尝试连接到 amqp：无法连接到 amqp://guest:**@127.0.0.1:5672//
Posted
技术标签:
【中文标题】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// 【发布时间】：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'),
,
【问题讨论】：
【参考方案1】：似乎您的 celery 连接选项有误。 Celery 正在尝试连接到 rabbitmq。我建议将broker_transport 设置为sqs，看看它是否仍然有效。
【讨论】：
以上是关于Celery sqs 尝试连接到 amqp：无法连接到 amqp://guest:**@127.0.0.1:5672//的主要内容，如果未能解决你的问题，请参考以下文章
Flask + Celery + Redis：消费者：无法连接到 amqp://guest:**@127.0.0.1:5672//：超时
创建第一个 Celery 任务 - Django。错误 - “错误/MainProcess] 消费者：无法连接到 amqp://guest:**@127.0.0.1:5672//:”
无法使用测试容器的 localstack 模块连接到 Aws SQS