如何解决Celery sqs尝试连接到amqp:无法连接到amqp://来宾:** @ 127.0.0.1:5672//
我想将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'),},}
解决方法
似乎您的芹菜连接选项错误。芹菜正试图连接到rabbitmq。我建议将broker_transport
设置为sqs
,看看它是否仍在工作。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。