Назад | Перейти на главную страницу

celery + redis + django [Errno 111] В соединении отказано

Не могу запустить celery worker + 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...

и если я запустил эту команду:

celery -A car_rental beat -l INFO

У меня такая ошибка:

[2020-02-24 16:42:01,535: ERROR/MainProcess] beat: Connection error: [Errno 111] Connection refused. Trying again in 2.0 seconds...

В моем settings.py у меня есть это:

BROKER_URL = 'redis://localhost:6379'

requirements.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))

прокат автомобилей/в этом.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//