尝试在 celery 任务文件中导入模型时尚未加载应用程序

Question

在任何解释之前，这是我的项目的树

| projectname
|____|__init__.py
|____|celery.py
|____|settings.py
|____|urls.py
|____|wsgi.py
|app1
|app2

这是我的 celery.py

from celery import Celery
from celery import shared_task

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'projectname.settings')
app = Celery('projectname')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()

from app1.models import *

@share_task
def tasks():
     ''' '''

每次我尝试使用 from app1.models import * 这一行将 models 导入到 celery.py 文件时，我得到了：

django.core.exceptions.AppRegistryNotReady：应用尚未加载。

本地服务器突然停止工作。 This post 与一个类似的问题有关，但不确定是不是这里的情况。

我想要将一些模型导入文件，以便我可以将它们用于一些查询。

我对可能出了什么问题有了一点线索，但不确定。

views 从 models.py
views 导入东西 celery.py strong> 喜欢要执行的任务
celery.py 尝试从 models 导入内容。

所以我觉得像蛇一样咬自己尾巴的圆圈很奇怪。

Answer 1

问题是当您尝试在 Django 加载配置（）之前上传您的任务

<b>from app1.models import *</b>

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'projectname.settings')
app = Celery('projectname')

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

当然，Celery 会检测 celery.py 文件中的任务，请记住，您已经导入了从 celery.py 到 __init__.py 的所有内容，以便让 Django 在每次项目启动时加载它们（Celery 的东西，...）。

__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 import app as celery_app

__all__ = ['celery_app']

因此，在这种情况下，您将在 celery.py 文件中导入模型，假设 __init.py__ 也是如此，您的模型将在 Django 加载其配置之前导入，而您的 settings.py 中的应用程序尚未构建。

您不应该将 Django 应用程序的东西导入您的 __init__.py 文件，模块/应用程序是在 Django 加载配置（settings.py）之前构建的，这将引发错误 应用程序尚未加载 如果您尝试在__init__.py 文件中上传models 之类的内容。

根据the documentation，Celery 拥有app.autodiscover_tasks() 能够发现在settings.INSTALLED_APPS 中任何注册良好的应用程序中找到的所有任务。无需在celery.py 中导入任务，只需在您的所有应用中创建一个tasks.py 文件即可。

| projectname
|____|__init__.py
|____|celery.py # contains app.autodiscover_tasks()
|____|settings.py
|____|urls.py
|____|wsgi.py
|app1
|____|tasks.py
|app2
|____|tasks.py

任务可能在celery.py 文件中工作，但在从应用上传模型时不能工作，请改用 app.autodiscover_tasks()

如果需要，也可以使用来自未来的绝对导入

from __future__ import absolute_import