如何在Django项目中运行后台任务？附__init__.py相关问题解答

一、__init__.py的核心作用 #

项目主目录和App目录下的__init__.py，本质是将所在目录标记为Python可导入包，让Python能识别目录内的模块文件。它仅用于包的初始化逻辑（比如导入子模块、定义包级变量），绝对不是用来编写启动时执行的业务代码的——这也是你触发AppRegistryNotReady错误的核心原因。

二、AppRegistryNotReady错误的根源 #

Django启动流程中，__init__.py会在App模型、数据库连接等核心组件初始化完成前被执行。你直接在里面写数据库操作代码，此时Django的App注册表还未加载完毕，自然无法访问模型和数据库，因此抛出该错误。

三、后台定时修改数据库的可行方案 #

针对你的需求，推荐两种成熟的实现方式，按需选择：

方案1：轻量定时任务——django-crontab #

适合逻辑简单、定时规则固定的场景：

1. 安装依赖：

pip install django-crontab

2. 在项目settings.py的INSTALLED_APPS中添加：

INSTALLED_APPS = [
    # 原有App
    'django_crontab',
]

3. 在目标App下创建tasks.py，编写数据库操作逻辑：

from django.utils import timezone
from .models import YourModel  # 替换为你的模型类

def update_database():
    # 示例：修改指定对象的字段
    target_obj = YourModel.objects.get(id=1)
    target_obj.updated_at = timezone.now()
    target_obj.save()

4. 在settings.py末尾配置定时规则（格式：分 时 日 月 周）：

CRONJOBS = [
    # 每天凌晨2点执行update_database
    ('0 2 * * *', 'your_app_name.tasks.update_database'),
]

5. 将定时任务注册到系统crontab：

python manage.py crontab add

6. 启动Django服务后，任务会自动后台运行，可通过以下命令管理：

# 查看已注册任务
python manage.py crontab show
# 删除任务
python manage.py crontab remove

方案2：复杂任务场景——Celery #

适合需要异步执行、定时规则灵活或任务逻辑复杂的场景（需Redis/RabbitMQ做消息队列，以下以Redis为例）：

1. 安装依赖：

pip install celery redis django-celery-beat

2. 在项目主目录创建celery.py：

import os
from celery import Celery

# 绑定Django配置文件
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'your_project_name.settings')

app = Celery('your_project_name')
app.config_from_object('django.conf:settings', namespace='CELERY')
# 自动发现所有App下的tasks.py
app.autodiscover_tasks()

3. 在项目主目录的__init__.py中添加（让Django识别Celery实例）：

from .celery import app as celery_app

__all__ = ('celery_app',)

4. 在settings.py中配置Celery：

CELERY_BROKER_URL = 'redis://localhost:6379/0'  # Redis服务地址
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'
CELERY_TIMEZONE = 'Asia/Shanghai'  # 替换为你的时区
CELERY_BEAT_SCHEDULER = 'django_celery_beat.schedulers:DatabaseScheduler'

5. 在目标App下创建tasks.py，编写异步任务：

from celery import shared_task
from .models import YourModel
from django.utils import timezone

@shared_task
def update_database():
    target_obj = YourModel.objects.get(id=1)
    target_obj.updated_at = timezone.now()
    target_obj.save()

6. 启动Celery组件：

# 启动任务执行Worker
celery -A your_project_name worker --loglevel=info
# 启动定时任务调度器Beat
celery -A your_project_name beat --loglevel=info

7. 若需可视化管理定时任务，将django_celery_beat加入INSTALLED_APPS，即可通过Django后台配置定时规则。

总结 #

• __init__.py仅用于包标记与基础初始化，禁止写入业务执行代码。
• 简单定时任务优先选django-crontab，复杂场景用Celery。
• 所有任务代码必须放在单独的tasks.py中，确保Django App加载完成后再执行数据库操作。

内容的提问来源于stack exchange，提问作者Hero