Celery и RabbitMQ не запускаются

Question

Я установил RabbitMQ, Celery, Flask и Python, но когда я попытался запустить работника сельдерея для тестирования.Это не работает, это ошибка, которая выскакивала в cmd.

[2019-01-18 09:56:37,443: WARNING/MainProcess] consumer: Connection to broker lost. Trying to re-establish the connection...
Traceback (most recent call last):
  File "c:\users\ansonkho\anaconda3\lib\site-packages\celery\worker\consumer\consumer.py", line 317, in start
    blueprint.start(self)
  File "c:\users\ansonkho\anaconda3\lib\site-packages\celery\bootsteps.py", line 119, in start
    step.start(parent)
  File "c:\users\ansonkho\anaconda3\lib\site-packages\celery\worker\consumer\mingle.py", line 40, in start
    self.sync(c)
  File "c:\users\ansonkho\anaconda3\lib\site-packages\celery\worker\consumer\mingle.py", line 44, in sync
    replies = self.send_hello(c)
  File "c:\users\ansonkho\anaconda3\lib\site-packages\celery\worker\consumer\mingle.py", line 57, in send_hello
    replies = inspect.hello(c.hostname, our_revoked._data) or {}

ниже мой код:

from celery import Celery

app = Celery('test_celery', broker='amqp://myuser:mypassword@localhost/myvhost',backend='rpc://')

Answer 1

[2019-01-18 09:56:37,443: WARNING/MainProcess] consumer: Connection to broker lost. Trying to re-establish the connection...

Как упомянуто в ошибке, не работает ни один брокер. Вам необходимо запустить Rabbitmq перед установкой соединения с ним. Вот почему потребитель выбрасывает Connection to broker lost, поскольку брокер не работает.