Не удается подключиться к amqp://guest:**@127.0.0.1:5672//:

Я хочу создать индикатор выполнения для одной из моих функций. Я вызываю эту функцию в представлениях. Я исследую и нахожу, что я должен использовать Celery для создания индикатора выполнения. (Я выполняю некоторые процессы загрузки, и пользователь должен отслеживать их)

Я нашел учебник и пытаюсь сделать то же самое, но получаю ошибку:

Не удается подключиться к amqp://guest:**@127.0.0.1:5672//: [WinError 10061]. Когда целевая машина активно отклоняет n соединение не удалось.

Я разрабатываю это приложение на localhost и использую sqlite для базы данных. Где моя ошибка и что мне делать?

settings.py

...
CELERY_ACCEPT_CONTENT = ['json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_BACKEND = 'django-db'
CELERY_BROKER_URL = '127.0.0.1'

functions.py

class myFunction():
 def __init__(self, user, password, url, port, db_password, username):
    ....
 @shared_task(bind=True)
 def send_download(self):
     progress_recorder = ProgressRecorder(self)
     for in_file in glob.glob(self.location + "\*\*.xyz"):
            try:
                i = 0
                progress_recorder.set_progress(i+1, len(array), f'On iteration {i}')

                with open(in_file) as f:
                    if os.path.getsize(in_file) > 0:
                        ... function...
                        time.sleep(0.02)
                i = i + 1
            except:
                pass
    ....

views.py

...
task = (functions.myFunction(setup.username, setup.password,
                                         setup.url, setup.port, setup.db_password,
                                         username=request.user.username))

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