请教怎么实现异步发送邮件

Posted 2023-04-08

参考技术A 告诉你一下：一般的处理方式是什么。写一个控制台程序，这个控制台的程序有三个功能。第一个功能，轮训数据库预发邮件表：每隔半个小时或者一个小时都可以。或者更长都行。根据业务来定。
第二个功能：发送邮件：从数据库用户表中，根据存在数据库中的用户表，或者筛选出来的用户表的信息，执行队列邮件发送并返回发送状态至数据库。
第三个功能：邮件发送完成后，向管理员或者发送邮件人发送邮件提示发送完成。或还有其他信息。本回答被提问者和网友采纳

Flask实战第67天：Flask+Celery实现邮件和短信异步发送

之前在项目中我们发送邮件和 短信都是阻塞的，现在我们来利用Celery来优化它们

官方使用文档： http://flask.pocoo.org/docs/1.0/patterns/celery/

redis服务器及插件，还有cerely在上节我们已经安装好，这里就不重复过程了。

首先，来完成邮件

在项目下新建tasks.py

from flask import Flask
import config
from celery import Celery
from flask_mail import Message
from exts import mail

##这里没有直接使用from bbs import app,是因为会出现循环引用的问题 
app = Flask(__name__)
app.config.from_object(config)
mail.init_app(app)


#在配置文件需要配置CELERY_RESULT_BACKEND、CELERY_BROKER_UR
def make_celery(app):
    celery = Celery(app.import_name, backend=app.config[‘CELERY_RESULT_BACKEND‘],
                    broker=app.config[‘CELERY_BROKER_URL‘])
    celery.conf.update(app.config)
    TaskBase = celery.Task
    class ContextTask(TaskBase):
        abstract = True
        def __call__(self, *args, **kwargs):
            with app.app_context():
                return TaskBase.__call__(self, *args, **kwargs)
    celery.Task = ContextTask
    return celery

celery = make_celery(app)


@celery.task
def send_mail(subject,recipients,body):
    message = Message(subject=subject,recipients=recipients,body=body)
    mail.send(message)

编辑config.py

# Celery相关配置
CELERY_RESULT_BACKEND = "redis://10.2.2.120:6379/0"
CELERY_BROKER_URL = "redis://10.2.2.120:6379/0"

编辑cms.views.py发送邮件的部分