celery使用rabbitmq報錯[Errno 104] Connection reset by peer.


寫好celery任務文件,使用celery -A app worker --loglevel=info啟動時,報告如下錯誤:

[2019-01-29 01:19:26,680: ERROR/MainProcess] consumer: Cannot connect to amqp://sunlight:**@127.0.0.1:5672/celery: [Errno 104] Connection reset by peer.
Trying again in 4.00 seconds...

 

檢查了很久,終於發現是celery配置的broker的url寫錯了,

rabbitmqctl add_user sunlight sunlight123

rabbitmqctl add_vhost /celery

rabbitmqctl set_permissions -p /celery sunlight   ".*"   ".*"   ".*" 

app = Celery(__name__, broker="amqp://sunlight:sunlight123@localhost:5672/celery", backend="redis://localhost")

上門的標紅處,顯然是錯誤的,應該替換為如下:

app = Celery(__name__, broker="amqp://sunlight:sunlight123@localhost:5672//celery", backend="redis://localhost")

即可解決問題。


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM