2

当他/她第一次登录（fb auth）到我们的烧瓶应用程序时，我正在尝试向用户发送一封欢迎电子邮件。

所以我正在考虑使用flask-mail作为电子邮件框架和芹菜（rabbitmq的python客户端）作为任务队列。

所以我有一个简单的电子邮件框架：

from flask.ext.mail import Message
from app import mail

    def send_email(subject, sender, recipients, text_body, html_body):
        msg = Message(subject, sender = sender, recipients = recipients)
        msg.body = text_body
        msg.html = html_body
        mail.send(msg)

我一直在阅读 celery 文档 - 但我不确定如何创建发送电子邮件所需的任务。我知道 Flask-mail 需要 Flask 应用程序上下文才能正常工作。然后我也需要 celery 的 celery 实例。那应该是烧瓶应用程序的一部分吗？简而言之，我正在寻找一些指导。在此先感谢您的帮助。

4

1 回答 1

2

您可以使用Grinberg 教程中所示的线程来执行此操作

from threading import Thread

def threading(f):
    def wrapper(*args, **kwargs):
        thr = Thread(target=f, args=args, kwargs=kwargs)
        thr.start()
    return wrapper

@threading
def send_email(subject, to, body, html=None):
    def send():
        try:
            mail.send(msg)
        except Exception as err:
            app.logger.error("Error during mail send: {0}".format(err))

    with app.app_context():
        msg = Message(subject, recipients=[to], body=body, html=html,
                      sender="welcome@myapp.net")

        send()

然后在您看来，您可以打电话send_email而不必等待

如果您想为电子邮件合并反馈（即发送电子邮件时出现错误的实时信息），您应该在实现中添加一个消息代理（即 rabbitmq、zeromq）和一个任务队列（即 celery）（以及异步轮询来自 UI 的消息的方法）。虽然我不认为你真的需要这样的欢迎电子邮件——除非你分批发送它们，你可以在这里找到一个如何使用这些东西的例子

于 2018-03-29T07:30:55.310 回答