django celery 无法启动 worker

Question

我在为我的 django 项目启动 celery worker 时遇到问题。感谢您在这里提供任何帮助。

我认为我不恰当地关闭了 celery 进程（首先是 ctrl+c，然后运行 "celery -A proj worker " 命令在完全关闭之前再次执行）。从那时起，我就再也无法启动我的 celery worker。它基本上没有给出来自命令行的响应，没有前进，没有错误，并且字面上没有任何反应。它只是卡在那里。

但是"celery worker"可以启动成功，只有"celery -A proj worker"失败

我也尝试重新安装我的 celery 和 rabbitmq，但这也无济于事。

有谁知道这里可能出了什么问题？我该如何解决这个问题？非常感谢您的帮助。

我的celery.py:

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

# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'webSite.settings')

app = Celery('webSite')

# Using a string here means the worker doesn't have to serialize
# the configuration object to child processes.
# - namespace='CELERY' means all celery-related configuration keys
#   should have a `CELERY_` prefix.
app.config_from_object('django.conf:settings', namespace='CELERY')

# Load task modules from all registered Django app configs.
app.autodiscover_tasks()


@app.task(bind=True)
def debug_task(self):
    print('Request: {0!r}'.format(self.request))

森

Answer 1

谢谢大家的帮助，我已经找到解决问题的方法了。

所以，每次我无法启动 celery worker 时，我都会关闭我的终端，因此下次进程仍然挂在那里。为我解决问题的方法是在芹菜进程挂在那里时终止进程 "kill -9"。

这解决了我的问题，但感谢大家的帮助。

森

django celery 无法启动 worker

django celery cannot start worker

django

celery

worker