Создание первого задания из сельдерея - Джанго. Ошибка - «ОШИБКА / MainProcess] получатель: не удается подключиться к amqp: // guest: **@127.0.0.1: 5672 //:» - PullRequest
Новая
       18

Создание первого задания из сельдерея - Джанго. Ошибка - «ОШИБКА / MainProcess] получатель: не удается подключиться к amqp: // guest: **@127.0.0.1: 5672 //:»

0 голосов
/ 27 июня 2019

Я пытаюсь создать свою первую задачу из сельдерея. Задача будет отправлять одно и то же сообщение электронной почты каждую минуту одному и тому же человеку.

Согласно документации, я создаю свою первую задачу в своем проекте. 

from __future__ import absolute_import, unicode_literals
from celery import shared_task
from django.core.mail import send_mail


@shared_task
def send_message():
    to = ['test@test.com', ]
    send_mail('TEST TOPIC',
              'TEST MESSAGE',
              'test@test.com',
              to)

Затем в папку ja моего проекта я добавляю файл celery.py, который выглядит следующим образом: 

from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
from django.conf import settings
from celery.schedules import crontab

# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'app_rama.settings')

app = Celery('app_rama')

# Using a string here means the worker doesn't have to serialize
# the configuration object to child processes.
# - namespace='CELERY' means all celery-related configuration keys
#   should have a `CELERY_` prefix.
app.config_from_object('django.conf:settings')

# Load task modules from all registered Django app configs.
app.autodiscover_tasks(settings.INSTALLED_APPS)


app.conf.beat_schedule = {
    'send-message-every-single-minute': {
        'task': 'app.tasks.send_message',
        'schedule': crontab(),  # change to `crontab(minute=0, hour=0)` if you want it to run daily at midnight
    },
}

Затем в __int__.py файле моего проекта я добавил: 

from __future__ import absolute_import, unicode_literals

# This will make sure the app is always imported when
# Django starts so that shared_task will use this app.
from .celery import app as celery_app

__all__ = ('celery_app',)

И последнее, что я пытаюсь сделать, это запустить команду: 

celery -A app_rama worker -l info

И тогда я получаю следующую ошибку: 

[2019-06-27 16:01:26,750: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: [WinError 10061]

Я перепробовал много решений с форума, но не нашел правильного. Мне также не помогло добавление следующих настроек в мой файл settings.py: 

CELERY_BROKER_URL = 'amqp://guest:guest@localhost:5672//'

Как я могу решить эту ошибку, чтобы моя задача работала в фоновом режиме приложения? Любая помощь будет оценена.

1 Ответ

1 голос
/ 28 июня 2019

Ваш брокер Celery, вероятно, неправильно настроен. Прочтите документ « Using RabbitMQ », чтобы узнать, как правильно настроить RabbitMQ (я предположил, что вы хотите использовать RabbitMQ, поскольку в вашем примере был протокол «amqp»).

Я рекомендую изучать Celery с Redis, так как его проще настроить и управлять им. Затем, как только вы изучите основы, вы можете перейти к RabbitMQ или другому поддерживаемому брокеру ...

Также убедитесь, что ваш сервер RabbitMQ работает правильно. Если вы используете Windows, убедитесь, что некоторые программы на ней не препятствуют подключению пользовательских процессов к localhost: 5672.

...