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