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

Flask怎么实现异步任务处理方式呢?有时候一次 http 请求的处理时间过长,而其中一部分代码又是不必同步执行的。我们就可以用以下函数把任务抛出去异步执行,同时接口立即返回。这个函数具体的执行过程是

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)