windows下利用django框架结合celery实现异步发送邮件功能，celery4.X以后的版本不再支持windows
-
By - C灵C
- 2019年5月27日 12:27
回家更新。
数据库采用 Redis 和 MySQL，提前建好表、配置路由、获取邮箱的授权码。
项目结构图如下所示：
settings.py中邮件配置如下：
# Django认证系统使用的模型类
AUTH_USER_MODEL = 'user.User'
# 发送邮件配置
EMAIL_BACKEND = 'django.core.mail.backends.smtp.EmailBackend'
# SMTP服务地址，使用其他服务器需更换
EMAIL_HOST = 'smtp.163.com'
EMAIL_PORT = 25
# 发送邮件的邮箱，换成自己的
EMAIL_HOST_USER = '17777788446@163.com'
# 在邮箱中设置的客户端授权密码，换成自己的
EMAIL_HOST_PASSWORD = 'cocpy.com'
# 收件人看到的发件人，<>中地址必须与上方保持一致
EMAIL_FROM = 'c0c<17777788446@163.com>'
最外层路由配置：
from django.contrib import admin
from django.urls import path, include
urlpatterns = [
path('admin/', admin.site.urls),
path('mail/', include(('apps.mail.urls', 'apps.mail'), namespace='mail')), # 邮件验证模块
]
配置mail模块下的路由，即mail下的urls.py,具体代码如下：
from django.urls import path, re_path
from apps.mail.views import VerifyMail, UserActivate
urlpatterns = [
path('verify/', VerifyMail.as_view(), name='verify'), # 邮件验证
re_path(r'^activate/(?P<token>.*)$', UserActivate.as_view(), name='activate'), # 用户激活
]
views.py中处理请求，安装 pip install itsdangerous进行加密，具体代码如下。
from itsdangerous import TimedJSONWebSignatureSerializer as TJSS
from itsdangerous import SignatureExpired
from django.shortcuts import render, HttpResponse, redirect, reverse
from django.views.generic import View
from django.conf import settings
from apps.mail.models import User
from celery_execute_task.sendmail import send_activate_email
# Create your views here.
class VerifyMail(View):
"""邮件验证功能"""
def get(self, request):
"""页面显示"""
return render(request, 'register.html')
def post(self, request):
"""业务处理"""
# 接收数据
username = request.POST.get('user_name')
password = request.POST.get('pwd')
phone = request.POST.get('phone')
email = request.POST.get('email')
# 校验数据
if not all([username, password, phone, email]):
# 缺少相关数据
return HttpResponse('校验数据失败')
user = User.objects.create_user(username, email, password, phone=phone)
# 正式处理发送邮件
# 加密用户的身份信息，生成激活token
serializer = TJSS(settings.SECRET_KEY, 900)
info = {'confirm': user.id}
token = serializer.dumps(info)
# 默认解码为utf8
token = token.decode()
# 使用celery发邮件
send_activate_email.delay(email, username, token)
return HttpResponse('注册成功，请注意查收激活账户邮件')
class UserActivate(View):
"""用户通过邮件激活功能"""
def get(self, request, token):
"""点击邮件链接激活业务处理"""
serializer = TJSS(settings.SECRET_KEY, 900)
try:
info = serializer.loads(token)
# 获取要激活用户的id
user_id = info['confirm']
# 根据id获取用户信息
user = User.objects.get(id=user_id)
user.is_active = 1
user.save()
# 跳转到登录页面
return HttpResponse('用户已成功激活！')
except SignatureExpired as se:
# 激活链接已过期，应重发激活邮件
return HttpResponse('激活链接已过期！')
重点 is coming
通过pip install celery安装celery，
如果是windows系统由于celery4.X版本不再支持windows，
所以还需安装eventlet即pip install enentlet。
在项目根目录下新建一个Python package，即结构图中的celery_execute_task
并在该包下新建sendmail.py文件用来执行异步任务，
具体代码如下：
import time
from django.core.mail import send_mail
from django.conf import settings
from celery import Celery
# 初始化django环境
import django
import os
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'djangoweb.settings')
django.setup()
# 创建实例对象
# 第一个parameter：可随意命名，但一般为本文件所在路径
# broker：指定中间人，斜杠后指定第几个数据库
app = Celery('celery_execute_task.sendmail', broker='redis://localhost:6379/3')
# 定义任务函数
@app.task
def send_activate_email(to_email, username, token):
"""发送激活邮件"""
# 组织邮件信息
subject = '明日科技欢迎您'
message = ''
sender = settings.EMAIL_FROM
receiver = [to_email]
html_message = '<h1>%s, 欢迎您注册明日科技会员</h1>请点击下面链接激活您的账户<br/><a href="http://127.0.0.1:8000/mail/activate/%s">http://127.0.0.1:8000/mail/activate/%s</a>' % (username, token, token)
send_mail(subject, message, sender, receiver, html_message=html_message)
time.sleep(5)
在MySQL和Redis启动的前提下，启动项目，通过命令启动celery即celery -A celery_execute_task.sendmail worker --loglevel=info -P eventlet，出现如下图所示即为启动成功。
访问前端页面，发送请求，查看邮件。
文章评论