Python Celery socket.error: [Errno 61] Соединение отклонено

Question

Я использую Celery 3.0 и имею конфигурационный файл, как показано ниже.

celeryconfig.py

BROKER_URL = 'redis://localhost:6379/0' 
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0' 
CELERY_TASK_SERIALIZER = 'json' 
CELERY_RESULT_SERIALIZER = 'json' 

CELERY_IMPORTS = ("tasks",) 
CELERY_TASK_RESULT_EXPIRES = 300 

tasks.py

import celery 

@celery.task 
def function(x,y): 
    return x + y 

и function.py

from tasks import function 

print function.delay(4,4).get() 

я запустить приложение с помощью следующей команды

celeryd --loglevel=INFO --config=celeryconfig 

Все отлично работает до сих пор. У меня есть redis и сельдерей работает и получить ответы.

Но когда я запускаю команду функции из другого файла с именем распараллеливатель,

Я получаю ошибку сокета,

socket.error: [Errno 61] Connection refused 

Мой файл находится, как показано ниже,

from examples.dummy.tasks import function 
print function.delay(4,4).get() 

Есть идеи?

Answer 1

Проблема была,

я бегу celeryconfig.py под от другого пути, чем мой распараллеливатель.

Когда я переносил celeryconfig.py на тот же путь с помощью параллелизатора, он исправил проблему.

Answer 2

У меня была такая же проблема, и проблема в том, что я пропустил этот код в __init__.py моего проекта:

from __future__ import absolute_import 

# 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 

Я надеюсь, что это будет полезно для кого-то там ...

Answer 3

Had та же проблема, закончилась тем, что процессы rabbitmq и redis были остановлены.

на макинтош, если эти услуги были установлены с помощью доморощенного, то вы можете проверить, является ли работают эти службы, выполнив следующую команду на терминале,

brew services list 

может перезапустить службы с помощью (если он установлен через brew)

brew services restart rabbitmq 
brew services restart redis