Невозможно получить работающий пример basi c Celery (Невозможно подключиться к amqp: // guest: **@127.0.0.1: 5672 //) - PullRequest
Новая
       51

Невозможно получить работающий пример basi c Celery (Невозможно подключиться к amqp: // guest: **@127.0.0.1: 5672 //)

0 голосов
/ 11 апреля 2020

Я следую учебнику Первые шаги с Celery , но не могу заставить его работать должным образом на моей локальной машине. Посмотрел несколько других вопросов и последовал их совету - но все равно не повезло.

Вот что я сделал:

  1. Я следовал Используя RabbitMQ Руководство и запуск сервера, используя sudo rabbitmq-server
  2. Я сохранил пример tasks.py (ниже) в моем рабочем каталоге
  3. Я запустил Celery, используя celery -A tasks worker --loglevel=info, однако, каждый раз, когда я запускаю эту команду, появляется ошибка (ниже)

tasks.py: 

from celery import Celery

app = Celery('tasks', broker='pyamqp://guest@localhost//')

@app.task
def add(x, y):
    return x + y

Я также пытался app = Celery('tasks', broker='amqp://myuser:mypassword@localhost:5672/myvhost'), очевидно, заменяя myuser, mypassword и myvhost на значения, которые я создал на шаге 1, но я получаю похожую ошибку.

Ошибка сельдерея: 

[2020-04-11 16:52:50,196: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: [Errno 92] Protocol not available.
Trying again in 2.00 seconds...

Я вырывал свои волосы, пытаясь получить основы c Сценарий работает, следуя документации, но безуспешно. Так что любая помощь будет принята с благодарностью!

...