接口中的简单异步 async

Posted 2020-12-13 nanyu

 

"""
首先梳理一下场景    有个发邮件需求   请求某个接口  接口返回成功之后 2后 发送邮件提醒
前提接口流程必须走完 有正确返回 项目中没有其他异步框架的时候   可以使用下边方式  做个简单的异步
1.写好异步装饰器， 
2.将需要延迟的操作写到函数中 将装饰器 放到函数头顶
3.正常走接口流程 代码不会堵塞
4.不说原理了(感觉有点low  不过有时可以解决问题)
"""

 

from threading import Thread
from time import sleep
def async(f):
    def wrapper(*args, **kwargs):
        thr = Thread(target=f, args=args, kwargs=kwargs)
        thr.start()
    return wrapper

@async
def get_ddos_status(account_name, customer_id, type_, flag, start):
    time.sleep(10)
    service.send_mail_(account_name, customer_id, type_, flag, start)