Celery如何使用Django ORM？跨服务器部署配置及代码疑问

1. 请问Celery如何使用Django ORM？ #

要让Celery能使用Django ORM，核心是让Celery Worker加载Django的运行环境，步骤如下：

• 在Django项目根目录创建celery.py文件，配置Celery关联Django设置：

import os
from celery import Celery

# 指定Django配置模块
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'your_project.settings')

app = Celery('your_project')
# 从Django配置中读取Celery参数，前缀为CELERY_
app.config_from_object('django.conf:settings', namespace='CELERY')
# 自动发现所有app中的tasks.py文件
app.autodiscover_tasks()

• 在项目根目录的__init__.py中添加代码，确保Django启动时加载Celery实例：

from .celery import app as celery_app

__all__ = ('celery_app',)

• 在任意Django app的tasks.py中定义任务，直接导入模型使用ORM：

from celery import shared_task
from myapp.models import MyModel

@shared_task
def count_active_items():
    # 直接用Django ORM操作数据
    active_count = MyModel.objects.filter(is_active=True).count()
    return active_count

• 启动Celery Worker时，在项目根目录执行命令，Worker会自动加载Django环境：

celery -A your_project worker --loglevel=info

2. Celery进程是否需要包含Django应用代码？ #

是的，Celery Worker进程必须包含完整的Django应用代码。因为Worker需要解析并执行调用Django模型、ORM的任务逻辑，这些操作依赖Django的模型定义、配置文件以及相关应用代码。如果Worker环境没有对应的Django代码，会出现导入错误或无法解析ORM查询的情况。

3. 当Django与Celery物理部署在不同服务器时，需要进行哪些配置，以及Celery如何调用Django中的代码？ #

必要配置： #

• 代码同步：Celery Worker所在服务器必须部署与Django服务器完全一致的Django项目代码，所有app、模型、配置文件的版本保持同步，避免代码差异导致任务执行失败。
• 共享消息中间件：配置公共的消息中间件（如Redis、RabbitMQ），确保Django服务器和Celery Worker都能访问该服务。在Django的settings.py和Celery配置中，设置相同的CELERY_BROKER_URL指向该中间件地址。
• 数据库权限开放：如果任务需要操作数据库，需允许Celery Worker所在服务器的IP访问Django使用的数据库，同时数据库账号拥有对应的读写权限。
• 环境变量配置：启动Celery Worker时，正确设置DJANGO_SETTINGS_MODULE环境变量，确保Worker能加载正确的Django配置。

代码调用方式： #

和同服务器部署的逻辑完全一致：在Django代码中导入定义好的Celery任务，调用异步执行（如count_active_items.delay()），任务会通过共享的消息中间件发送给Celery Worker。Worker接收到任务后，在自身环境中加载Django代码，执行任务中的ORM操作及其他业务逻辑。

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