Python celery socket.error : [Errno 61] Connection refused

Question

我正在使用 Celery 3.0 并具有如下配置文件。

celery 配置.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

任务.py

import celery

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

和函数.py

from tasks import function

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

我使用以下命令运行应用程序

celeryd --loglevel=INFO --config=celeryconfig

到目前为止一切正常。我让 redis 和 celery 运行并得到答案。

但是当我从另一个名为 parallelizer 的文件运行函数命令时，

我收到套接字错误，

 socket.error: [Errno 61] Connection refused

我的文件如下，

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

有什么想法吗？

Answer 1

有同样的问题，最终意识到 rabbitmq 和 redis 进程已停止。

在 mac 上，如果这些服务是通过 homebrew 安装的，那么您可以通过在终端上运行以下命令来验证这些服务是否正在运行，

brew services list

可以重启服务，(如果通过 brew 安装)

brew services restart rabbitmq
brew services restart redis