Django celery异步发送邮件

你的名字 2023-01-09 15:48 178阅读 0赞

# Django celery异步发送邮件 #

使用基于Django搭建的后端框架，并使用celery进行异步发送邮件。

##### 1.setting.py文件中配置 #####

"""配置邮件服务器"""
    # 指定邮件后端
    EMAIL_BACKEND = 'django.core.mail.backends.smtp.EmailBackend'
    
    # 发邮件主机
    EMAIL_HOST = 'smtp.263.net'
    
    # 发邮件端口
    EMAIL_PORT = 25
    
    # 授权的邮箱
    EMAIL_HOST_USER = 'xxx@xxx.com'
    
    # 邮箱授权时获得的密码，非注册登录密码
    EMAIL_HOST_PASSWORD = 'xxxxxxx'
    
    # 发件人抬头
    EMAIL_FROM = 'xxx@xxx.com'
    
    # 关闭TLS发送邮件
    EMAIL_USE_TLS = False

##### 2.在项目中建立一个`Python Package`,进入该目录并在该目录下建立config.py文件。 #####

目录结构如下：

worker$ tree
    .
    ├── config.py
    └── __init__.py

init文件

import os
    
    from celery import Celery
    
    from worker import config
    
    # 加载django的环境
    os.environ.setdefault("DJANGO_SETTINGS_MODULE", "la.settings")
    
    # 实例化celery
    celery_app = Celery('la')
    
    # 加载配置文件
    celery_app.config_from_object(config)
    
    # 自动注册任务
    celery_app.autodiscover_tasks()

config文件

# 把任务放到哪一个队列
    broker_url = 'redis://127.0.0.1:6379/0'
    
    # 设置时区
    enable_utc = True
    timezone = 'Asia/Shanghai'

##### 3.**创建发送邮件函数** #####

from django.core.mail import send_mail
    
    from worker import celery_app
    
    
    @celery_app.task
    def email(email_messages, recipient_list):
        """ 发送邮件 :param email_messages: HTML格式邮件内容 :param recipient_list: 收件人清单列表 :return: """
    
        send_mail(
            subject='测试邮件！',
            message='',
            from_email='xxx@xxx.com',
            recipient_list=recipient_list,
            html_message=email_messages,
        )

##### 4.调用函数 #####

from common.common import email
    
    
    # 邮件内容
    email_messages = '<h1 align="center">测试邮件</h1>'
    
    # 收件人清单
    recipient_list = ['xxx@xxx.com']
    
    # 发送邮件
    email(email_messages, recipient_list)