大家晚上好,当客户完成订单时,有一个基于 Django 3.1 构建的在线商店网站,他收到一封包含信息的电子邮件,我通过
这是一段代码
import threading
t = threading.Thread(target=send_pochta, args=(sh.email, order.id))
t.start()
效果不错,就是不知道怎么走得更远,还是设置celery比较好?求指教,通过线程构建更容易,或者还有其他异步功能,谢谢
大家晚上好,当客户完成订单时,有一个基于 Django 3.1 构建的在线商店网站,他收到一封包含信息的电子邮件,我通过
这是一段代码
import threading
t = threading.Thread(target=send_pochta, args=(sh.email, order.id))
t.start()
效果不错,就是不知道怎么走得更远,还是设置celery比较好?求指教,通过线程构建更容易,或者还有其他异步功能,谢谢
threading此处不适合使用,尤其是在需要可靠的邮件传递时。如果发送时发生错误,或者执行它的进程死亡(这甚至可以定期发生,例如,gunicorn 可以定期重启工作进程,比如在每处理 1000 个请求之后),那么在这种情况下,关于什么的信息,原则上需要发送的邮件会丢失。那些。此信息仅存储在内存中(以正在运行的线程的形式),如果进程失败,那么所有这些都将丢失。
正是为此,需要某种机制来存储有这样一项任务的信息 - 发送邮件。例如,如果我们使用 celery,那么这将成为任务队列的一个元素以供执行。如果你正确配置了 celery(并且默认情况下,它不是这样工作的),那么如果在发送消息时发生错误,或者 celery 进程死亡,则将重复该操作。
另一个微妙的地方是,当执行订单完成操作时,在一个简单的实现中,会执行两个操作:
第 2 步的机制(即 celery 中的线程或任务)对于我要演示的问题并不重要。让我们假设首先保存在数据库中,然后创建任务。有时(很少,但仍然),如果在步骤 1 之后查询执行过程失败,那么步骤 2 中的任务将永远不会被创建。
当然,有时不发送通知的可接受程度是很重要的。如果不允许这样做,那么有办法使其可靠。
比如你可以先创建一个任务(既然需要可靠性,那么这里就不适合线程化了),然后保存。但同时,发送邮件的任务必须为以下事实做好准备:
那些。启动时的任务应检查订单是否实际保存,然后发送邮件。否则,它会延迟一段时间,比如说将自己放入队列中以在 10 秒内启动。如果在下一次启动时订单仍未保存,但已经过去了很多时间,则任务决定情况 2 发生,即 订单将不再保存,并结束其工作。
另一个更复杂的选项是使用最终一致性,如在此处详细描述的那样。