Сельдерей не работает: не удается подключиться к amqp: // guest: **@127.0.0.1: 5672 //

Question

Не могу запустить сельдерея + докер + джанго. Я загружаю изображение кролика и связанного работника, и при запуске я получаю сообщение об ошибке: Не удается подключиться к amqp: // guest: **@127.0.0.1: 5672 //: [Errno 111] Соединение отклонено. worker_1. Джанго: 1.11, калорийность: 4.1.0. Что делаешь не так?

докер-Compose

rabbit:
  image: rabbitmq:latest
  ports:
    - "5672:5672"

worker:
  build: ./project
  volumes:
    - ./main:/src/app
  depends_on:
    - rabbit
  links:
    - web #django project
  entrypoint: /src/app/calery.sh

Calery

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

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'app.settings')

app = Celery('app')

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

app.autodiscover_tasks()

@app.task(bind=True)
def add():
   print('Task')

celery.sh

#!/bin/bash

cd app
celery -A app worker -l info

Answer 1

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

http://docs.celeryproject.org/en/latest/getting-started/brokers/rabbitmq.html#broker-rabbitmq

Answer 2

Ошибка вызвана неверным хостом для CELERY_BROKER_URL. Судя по предоставленной вами ошибке, кажется, что хост в вашем URL-адресе брокера 127.0.0.1, так как вы используете docker, это не будет работать, если вы не предоставите публичный IP-адрес своего хоста. Вам необходимо обновить хост в вашем CELERY_BROKER_URL, чтобы использовать имя сервиса в вашем файле компоновки. В вашем случае это rabbit. Должно работать что-то вроде ниже:

CELERY_BROKER_URL = 'amqp://guest:guest@rabbit:5672/%2F'

Смена пользователя, пароля и других деталей.