Django集成Celery+RabbitMQ异步任务报无GET属性错误排查

• 你为gerar_pdf配置了bind=True参数，该参数下被装饰的任务函数第一个入参固定为Celery任务实例本身，你将该位置的参数错认为Django请求对象，尝试访问其.GET属性时，实际访问的是任务实例，直接触发属性不存在的报错。
• Django的HttpRequest是绑定单次请求生命周期的临时上下文对象，内部包含WSGI连接句柄、会话缓存、临时文件引用等大量不可序列化内容，你配置的JSON序列化规则无法将完整request对象传递给独立运行的Celery worker进程；即便更换序列化方式强行传递，跨进程后对象内部的上下文连接已经完全失效，根本无法正常使用。

1. 确认基础配置符合规范 #

项目级celery.py配置 #

import os
from celery import Celery

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'proj.settings')
# 初始化名为proj的Celery实例
app = Celery('proj')
# 从Django settings加载配置，配置前缀为CELERY
app.config_from_object('django.conf:settings', namespace='CELERY')
# 配置RPC作为结果后端
app.conf.result_backend = 'rpc://'
# 自动发现所有已注册Django应用下的tasks.py模块，无需手动指定加载app.tasks
app.autodiscover_tasks()

settings.py Celery配置段 #

CELERY_BROKER_URL = 'amqp://guest:guest@localhost:5672//'
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_ACCEPT_CONTENT = ['json']

项目级__init__.py配置 #

from .celery import app as celery_app

__all__ = ('celery_app',)

2. 修正异步任务定义 #

禁止传入request对象，仅接收可JSON序列化的基础类型参数，注意bind=True时第一个参数固定为任务实例self：

# app/tasks.py
from celery import shared_task
from django.core.mail import send_mail
from .models import Dashboard
import logging

logger = logging.getLogger(__name__)

@shared_task(
    bind=True,
    max_retries=3,
    default_retry_delay=20,
    # 配置需要自动重试的异常类型，可根据业务替换为网络超时、连接错误等具体临时故障异常
    autoretry_for=(ConnectionError, TimeoutError),
)
def gerar_pdf(self, uuid, user_email, username):
    """异步生成PDF报告并发送通知邮件"""
    # 通过传入的uuid查询Dashboard数据，无需依赖request对象
    dashboard_data = Dashboard.objects.get(uuid=uuid)
    # 执行PDF生成逻辑，基于dashboard_data渲染报告内容
    # pdf_bytes = render_dashboard_pdf(dashboard_data)
    # 发送带附件的通知邮件
    # send_mail(
    #     subject="您的Dashboard报告已生成",
    #     message=f"您好{username}，附件为您申请的Dashboard PDF报告",
    #     from_email="system@yourdomain.com",
    #     recipient_list=[user_email],
    #     # attachments=[("dashboard_report.pdf", pdf_bytes, "application/pdf")]
    # )
    return {"status": "success", "uuid": uuid}

3. 修正视图层任务触发逻辑 #

在视图的请求生命周期内，从request对象中提取所有任务需要的纯数据参数，再传递给异步任务，禁止直接传入request实例：

# app/views.py
from django.shortcuts import render
from django.contrib.auth.decorators import login_required
from .tasks import gerar_pdf

@login_required
def DashboardViewPdf(request):
    # 在当前请求上下文中提取任务需要的所有可序列化参数
    req_uuid = request.GET.get('uuid')
    if not req_uuid:
        return render(request, "error.html", {"msg": "缺少必要的uuid参数"})
    current_user = request.user
    # 提取发邮件、生成PDF需要的用户信息
    task_params = {
        "uuid": req_uuid,
        "user_email": current_user.email,
        "username": current_user.username
    }
    # 触发异步任务，仅传入基础类型参数
    gerar_pdf.delay(**task_params)
    # 立即返回渲染响应，无需等待任务执行完成
    return render(request, "pdf_task_loading.html", {"task_uuid": req_uuid})

• 所有传递给Celery任务的参数必须是可JSON序列化的基础类型：字符串、数字、布尔值、字典、列表，禁止传递Django模型实例、request对象、文件句柄、数据库连接这类带上下文状态的对象，需要使用对应数据时，在worker进程内通过传入的唯一标识重新查询即可。
• 自动重试规则不要直接捕获所有Exception，仅针对网络波动、第三方服务临时不可用这类可恢复的故障配置重试，参数错误、数据不存在这类逻辑错误不要触发重试，避免无意义的资源消耗。

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