Django 集成 Celery 实现异步邮件发送完整指南
发布时间：2026-10-13| 5人浏览过
本文详细介绍如何在 Django 项目中集成 Celery 实现异步邮件发送。涵盖依赖安装、settings 配置、.env 环境变量设置、celery_app.py 与 tasks.py 编写，以及 Worker 启动方法。通过 Redis 区分任务队列与结果存储，确保邮件发送不阻塞主线程，提升应用性能。
安装依赖与配置准备
首先需要安装必要的依赖包。
pip install django-celery-beat
pip install django-celery-email
pip install celery
pip install msgpack-python
pip install msgpack接着在 Django 项目的 settings 文件中进行相关配置。
确保将相关的 app 添加到 INSTALLED_APPS 列表中。
"djcelery_email",
"django_celery_beat"修改项目中的 .env 配置文件以定义环境变量。
#邮箱后端，使用celery email
DJANGO_EMAIL_BACKEND=djcelery_email.backends.CeleryEmailBackend
DJANGO_EMAIL_HOST=smtp.qq.com
DJANGO_EMAIL_HOST_USER=xxx@qq.com # 您的邮箱号
DJANGO_EMAIL_HOST_PASSWORD=你的邮箱密码
DJANGO_DEFAULT_FROM_EMAIL=默认发送的邮箱号
#CELERY
CELERY_BROKER_URL=redis://127.0.0.1:6379/1 #使用redis 1作为消息代理
CELERY_RESULT_BACKEND=redis://127.0.0.1:6379/2 #把任务结果放在redis2库中
在 .env 文件中添加 Celery 的基础配置项。
# Celery
# ------------------------------------------------------------------------------
if USE_TZ:
# http://docs.celeryproject.org/en/latest/userguide/configuration.html#std:setting-timezone
CELERY_TIMEZONE = TIME_ZONE
# http://docs.celeryproject.org/en/latest/userguide/configuration.html#std:setting-broker_url
CELERY_BROKER_URL = env("CELERY_BROKER_URL")
# http://docs.celeryproject.org/en/latest/userguide/configuration.html#std:setting-result_backend
CELERY_RESULT_BACKEND = env('CELERY_RESULT_BACKEND')
# http://docs.celeryproject.org/en/latest/userguide/configuration.html#std:setting-accept_content
CELERY_ACCEPT_CONTENT = ["json", 'msgpack']
# http://docs.celeryproject.org/en/latest/userguide/configuration.html#std:setting-task_serializer
CELERY_TASK_SERIALIZER = "msgpack"
# http://docs.celeryproject.org/en/latest/userguide/configuration.html#std:setting-result_serializer
CELERY_RESULT_SERIALIZER = "json"
# http://docs.celeryproject.org/en/latest/userguide/configuration.html#task-time-limit
# TODO: set to whatever value is adequate in your circumstances
CELERY_TASK_TIME_LIMIT = 5 * 60
# http://docs.celeryproject.org/en/latest/userguide/configuration.html#task-soft-time-limit
# TODO: set to whatever value is adequate in your circumstances
CELERY_TASK_SOFT_TIME_LIMIT = 60
# http://docs.celeryproject.org/en/latest/userguide/configuration.html#beat-scheduler
CELERY_BEAT_SCHEDULER = "django_celery_beat.schedulers:DatabaseScheduler"
EMAIL_BACKEND = env(
"DJANGO_EMAIL_BACKEND", default="djcelery_email.backends.CeleryEmailBackend"
)
同时添加邮箱服务的具体配置参数。
EMAIL_HOST = env('DJANGO_EMAIL_HOST', default="smtp.qq.com")
EMAIL_USE_SSL = env('DJANGO_EMAIL_USE_SSL', default=True)
EMAIL_PORT = env('DJANGO_EMAIL_PORT', default=465)
EMAIL_HOST_USER = env('DJANGO_EMAIL_HOST_USER')
EMAIL_HOST_PASSWORD = env('DJANGO_EMAIL_HOST_PASSWORD')
DEFAULT_FROM_EMAIL = env('DJANGO_DEFAULT_FROM_EMAIL')Celery 应用与任务定义
接下来需要编写 Celery 的核心逻辑文件。
在项目配置的目录下新建 celery_app.py 文件，用于初始化 Celery 应用实例。
import os
from celery import Celery
# set the default Django settings module for the 'celery' program.
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "config.settings.production")
app = Celery("你的项目名")
# Using a string here means the worker doesn't have to serialize
# the configuration object to child processes.
# - namespace='CELERY' means all celery-related configuration keys
# should have a `CELERY_` prefix.
app.config_from_object("django.conf:settings", namespace="CELERY")
# Load task modules from all registered Django app configs.
app.autodiscover_tasks()
在具体的 app 目录下创建 tasks.py 文件，用于定义异步任务。
from django.conf import settings
from django.core.mail import send_mail
from config import celery_app
# 打上装饰器celery就会自动搜索到添加到任务中
@celery_app.task()
def send_activity_verify_email():
"""异步发送新订单邮件"""
title = '[学时通] 您有一个新活动等待审核'
message = '您有一个新活动等待审核，请进入学时通管理系统查看'
send_mail(title, message=message, from_email=settings.DEFAULT_FROM_EMAIL,
recipient_list=settings.EMAIL_RECIPIENT_LIST)
启动 Celery Worker 与运行机制
配置完成后，启动 Celery Worker 进程。
进入项目的根目录执行启动命令。
执行以下命令来启动 Worker：
其中 config 代表项目配置目录，config.celery_app 指向该目录下的 celery_app 模块。
$ /usr/local/python3/bin/celery -A config.celery_app worker -l info
当用户触发发送邮件操作时，Celery 会将任务推送到 Redis 的第 1 号数据库作为消息代理；邮件发送任务执行完毕后，结果会存储在 Redis 的第 2 号数据库中。
以上即为 Django 集成 Celery 发送异步邮件的完整实现步骤，供参考使用。
免责声明：本文内容仅供参考，不代表本站观点。转载或引用请注明出处。
