celery 异步发送邮件

from __future__ import absolute_import, unicode_literals
import os
from celery import Celery

# 设置环境变量
os.environ.setdefault(‘DJANGO_SETTINGS_MODULE‘, ‘项目名.settings‘)

# 注册Celery的APP
app = Celery(‘项目名‘)
# 绑定配置文件
app.config_from_object(‘django.conf:settings‘, namespace=‘CELERY‘)

# 自动发现各个app下的tasks.py文件
app.autodiscover_tasks()

# 发送方 邮箱账户
my_mail = ‘4544****@qq.com‘
# 发送发 邮箱授权码
my_pass = ‘d*****‘




# celery  参数

CELERY_BROKER_URL = ‘redis://127.0.0.1:6379/‘

CELERY_RESULT_BACKEND = ‘redis://127.0.0.1:6379/‘

CELERY_RESULT_SERIALIZER = ‘json‘

from __future__ import absolute_import, unicode_literals
from .celery import app as celery_app

#导包
import pymysql
#初始化
pymysql.install_as_MySQLdb()



__all__ = [‘celery_app‘]

from syl.settings import *
from celery.task import task

# 定义发送邮件的方法
@task
def send_mail(subject, content, mailaddr):
    
    sleep(5)
    res = True
    try:
        # 声明邮件对象
        msg = MIMEText(content, ‘plain‘, ‘utf-8‘)

        # 设置发送方对象
        msg[‘From‘] = formataddr([‘自定义标题‘, my_mail])

        # 设置收件方对象
        msg[‘To‘] = formataddr([‘尊敬的客户‘, mailaddr])

        # 设置标题
        msg[‘Subject‘] = subject

        # 设置smtp服务器
        server = smtplib.SMTP_SSL("smtp.qq.com", 465)

        # 登录邮箱
        server.login(my_mail, my_pass)

        # 发送邮件
        server.sendmail(my_mail, [mailaddr], msg.as_string())

        # 关闭smtp链接
        server.quit()
    except Exception as e:
        print(e)
        res = False
        return res
    return res

class Send_email(APIView):

    # 注册
    def post(self, request):
# 接收邮件的 邮箱    
        email= request.POST.get(‘email‘)

        user = User.objects.filter(email=email)
if user:
            return Response({‘code‘: 222, ‘message‘: ‘该用户名已被注册‘})
try:
           # 邮件
            subject = "账号激活"
            content = ‘自定义内容‘

            mail.delay(subject, content,email)
 
         return Response({‘code‘: 200, ‘address‘: ‘验证链接已发送到您的邮箱，请前往激活账号‘})

        except Exception as e:

            print(e)
            return Response({‘code‘: 400})

celery worker -A 项目名 --loglevel=info --pool=solo