Django Celery worker未接收任务 异步发送邮件无响应问题

问题根因 #

1. 调用send_activation_email.delay(t_user)时直接传递了Django ORM模型实例作为参数，当前配置的JSON序列化器无法序列化自定义ORM对象，导致任务下发失败，不会推送到消息队列，Worker自然也接收不到任务。
2. 其他可能的异常点：Celery实例未在Django启动时正确加载、Redis Broker服务异常、Worker启动时未指定正确的任务模块。

修复步骤 #

1. 调整任务参数为可序列化的基础类型 #

不要直接传递ORM实例，改为传递用户ID，在任务内部查库获取用户对象：

修改tasks.py逻辑

from django.contrib.auth import get_user_model
User = get_user_model()

@app.task(name="send_activation_email")
def send_activation_email(user_id):
    # 任务内部查询获取用户实例
    user = User.objects.get(id=user_id)
    # 原有业务逻辑保持不变
    to = user.email
    subject = 'Activate Your %s Account' % user.get_user_role_display()
    text_content = ''
    uid = urlsafe_base64_encode(
        force_bytes(user_id))

    token = account_activation_token.make_token(user)
    c = ({'user': user,
          'user_type': user.user_role,
          'base_url': base_url, 'token': token, 'uid': uid, 'text_content': text_content})
    html_content = get_template('mail/user/invite.html').render(c)
    msg = EmailMultiAlternatives(
        subject, text_content, from_email, [to])
    msg.attach_alternative(html_content, "text/html")
    msg.send()

修改views.py调用逻辑

把原有的实例传递改为传递用户ID：

# 替换send_activation_email.delay(t_user)为以下代码
send_activation_email.delay(t_user.id)

2. 排查其他配置问题（修改参数后仍异常时排查） #

• 确认Redis服务正常运行，无密码、端口占用等访问异常，CELERY_BROKER_URL配置和实际Redis访问地址一致
• 确认Celery实例在Django项目根目录的__init__.py中正确导入：

# 项目根目录__init__.py
from .celery import app as celery_app

__all__ = ('celery_app',)

• 启动Worker时指定正确的项目应用模块，示例启动命令（替换为你自己的项目名）：
  celery -A 你的项目名 worker --loglevel=info

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