Django：Celery 找不到我的应用程序

Question

ModuleNotFoundError: No module named 'myapp'

我真的不明白这里的问题是什么。我的应用程序没有问题，但无论我尝试和更改什么，celery 似乎都找不到它。

这是我的目录结构：

django
 / mysite
     __init__.py
     celery.py
     settings.py
     urls.py
     wsgi.py
     / myapp
       admin.py
       apps.py
       models.py
       tasks.py
       urls.py
       views.py
   manage.py

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', 'mysite.settings')

app = Celery('myapp')

# Using a string here means the worker don'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))

命令：celery -A myapp worker -l info

Answer 1

确保您的 init.py 文件包含以下内容：

from __future__ import absolute_import, unicode_literals

# This will make sure the app is always imported when
# Django starts so that shared_task will use this app. from .celery_worker import app as celery_app

__all__ = ['celery_app']

另外，请确保您的 celery.py 看起来与此类似

from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
from celery.schedules import crontab
import mysite

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

app = Celery('wellfie')

# Using a string here means the worker don'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))

确保您的任务也被正确识别： 例如，共享任务看起来像

@shared_task(name="mysite.myapp.tasks.simple_task") 编辑。

实际上，您需要将 myapp 移出 mysite 并进入 Django 文件夹。我也会将 Django 文件夹重命名为 mysite，这样您就有了父文件夹 mysite、子文件夹 mysite，其中包含 wsgi、芹菜、设置等，子文件夹 myapp

Answer 2

您的celery.py 文件应位于myapp 文件夹中。 (http://docs.celeryproject.org/en/latest/django/first-steps-with-django.html)

您应该在mysite 文件夹中运行 celery -A myapp worker -l info。