celery + redis Невозможно подключиться к amqp: // guest: **@127.0.0.1: 5672 //: [Errno 111] Соединение отклонено - PullRequest
Новая
       25

celery + redis Невозможно подключиться к amqp: // guest: **@127.0.0.1: 5672 //: [Errno 111] Соединение отклонено

0 голосов
/ 24 февраля 2020

Не могу запустить сельдерея + redis + django. Если я запускаю эту команду, чтобы проверить, что работник сельдерея готов к приему задач: 

celery -A car_rental worker -l info

Я получил эту ошибку: 

[2020-02-24 00:14:42,188: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: [Errno 111] Connection refused.
Trying again in 2.00 seconds...

В моем файле settings.py у меня есть это: 

BROKER_URL = 'redis://localhost:6379'

needs.txt: 

amqp==2.5.2, asgiref==3.2.3, billiard==3.6.2.0, celery==4.4.0, redis==3.4.1

celery.py: 

from __future__ import absolute_import, unicode_literals
import os
from celery import Celery

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'car_rental.settings')

app = Celery('car_rental')

app.config_from_object('django.conf:settings', namespace='CELERY')

app.autodiscover_tasks()


@app.task(bind=True)
def debug_task(self):
    print('Request: {0!r}'.format(self.request))

car_rental / init .py: 

from __future__ import absolute_import, unicode_literals
from .celery import app as celery_app

__all__ = ('celery_app',)

и структура моего проекта выглядит следующим образом: 

 car_rental
           /car_rental
               __init__.py
               celery.py
               setting.py

Чего я не понял, так это того, что я использую в broker_url = 'redis://localhost:6379', но у меня есть ошибка: Cannot connect to amqp://guest:**@127.0.0.1:5672//

1 Ответ

0 голосов
/ 24 февраля 2020

Я устал устанавливать RabbitMQ с помощью этой команды: 

(venv) ~/OC_project13/car_rental$ sudo apt-get install rabbitmq-server

И я проверил, что rabbitmq работает: 

(venv) ~/OC_project13/car_rental$ systemctl status rabbitmq-server

● rabbitmq-server.service - RabbitMQ Messaging Server
   Loaded: loaded (/lib/systemd/system/rabbitmq-server.service; enabled; vendor preset: enabled)
   Active: active (running) since Mon 2020-02-24 17:04:34 CET; 6min ago
 Main PID: 15243 (rabbitmq-server)
    Tasks: 92 (limit: 4915)
   CGroup: /system.slice/rabbitmq-server.service
           ├─15243 /bin/sh /usr/sbin/rabbitmq-server
           ├─15252 /bin/sh /usr/lib/rabbitmq/bin/rabbitmq-server
           ├─15457 /usr/lib/erlang/erts-9.2/bin/epmd -daemon
           ├─15531 /usr/lib/erlang/erts-9.2/bin/beam.smp -W w -A 64 -P 1048576 -t 5000000 -stbt db -zdbbl 32000 -K true -B i -- -root /usr/lib/erlang -p
           ├─15643 erl_child_setup 65536
           ├─15716 inet_gethost 4
           └─15717 inet_gethost 4

févr. 24 17:04:30 rouizi systemd[1]: Starting RabbitMQ Messaging Server...
févr. 24 17:04:30 rouizi rabbitmq[15244]: Waiting for rabbit@rouizi
févr. 24 17:04:30 rouizi rabbitmq[15244]: pid is 15252
févr. 24 17:04:34 rouizi systemd[1]: Started RabbitMQ Messaging Server.

, и теперь запущенный рабочий сервер сельдерея не вернуть любую ошибку: 

(venv) ~/OC_project13/car_rental$ celery -A car_rental worker -l INFO

-------------- celery@rouizi v4.4.0 (cliffs)

......
......

[2020-02-24 17:11:55,568: INFO/MainProcess] celery@rouizi ready.
...