flask异步处理耗时任务 Flask怎么实现异步任务处理方式呢？

Flask怎么实现异步任务处理方式呢？

有时候一次 http 请求的处理时间过长，而其中一部分代码又是不必同步执行的。我们就可以用以下函数把任务抛出去异步执行，同时接口立即返回。

这个函数具体的执行过程是：

调用时复制当前请求上下文 (request)

原请求立即继续执行

func 被执行时，复制的 request 会被 push，从此这就可以被认为是一个全新的任务

须注意的是，因为复制的请求是被 push 进来的，所以 before_request 的信号不会被触发。但之后的 after_request 和 tear_doen_request 还会有。以及，因为只复制了 request，其他的上下文变量，如 g，是没有被复制的。

lang:python

import gevent

from flask import copy_current_request_context

def i_have_a_dream(func， *args， **kwargs):

"""

异步任务处理。本函数会立即返回，并使用 gevent 的新线程执行 func 函数（带 request 上下文）。

"""

return gevent.spawn(copy_current_request_context(func)， *args， **kwargs)

flask异步处理耗时任务 flask异步非阻塞 flask异步

版权声明：本文内容由互联网用户自发贡献，本站不承担相关法律责任.如有侵权/违法内容,本站将立刻删除。