首页 > 其他 > 详细

Flask 的异步任务处理

时间:2015-05-22 11:45:59      阅读:553      评论:0      收藏:0      [点我收藏+]

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

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

  1. 调用时复制当前请求上下文 (request)
  2. 原请求立即继续执行
  3. func 被执行时,复制的 request 会被 push,从此这就可以被认为是一个全新的任务

须注意的是,因为复制的请求是被 push 进来的,所以 before_request 的信号不会被触发。但之后的 after_requesttear_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 的异步任务处理

原文:http://my.oschina.net/lionets/blog/418128

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!