Django celery задержка функция использовать гость пользователь

Здравствуйте, я хочу использовать задачи celery в моем проекте Django

Когда я запускаю celery -A proj worker -l INFO все хорошо, он подключается к серверу rabbitmq

Но у меня проблема, когда я запускаю задание add.delay(1, 1) я получаю ответ (403) ACCESS_REFUSED - Login was refused using authentication mechanism PLAIN. For details see the broker logfile.

В лог-файле я вижу 2022-01-16 23:15:51.898981+00:00 [erro] <0.1093.0> PLAIN login refused: user 'guest' - invalid credentials. Я понимаю, что функция celery delay использует неправильного пользователя guest и не saar

мой файл в моем проекте

celery.py

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

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'proj.settings')
app = Celery('proj')

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

app.autodiscover_tasks()

settings.py

CELERY_TASK_TRACK_STARTED = True
CELERY_BROKER_URL = 'amqp://saar:1234567s@localhost'

init.py

from .celery import app as celery_app
__all__ = ('celery_app',)

tasks.py

from __future__ import absolute_import, unicode_literals
from celery import shared_task

@shared_task
def add(x, y):
    return x + y

Мои пакеты: Django 3.2.11, celery 5.2.3, flower 1.0.0, django-celery-beat 2.2.1

Что я могу сделать, чтобы исправить это?

Вернуться на верх