Flask 跑在 Tornado 上，使用 requests 库导致阻塞的问题

[woostundy]

服务是 Flask 写的，外面套了层 Tornado ，该怎么让 requests 变成非阻塞？

[DozySun]

tornado 换成 gunicorn+gevent

[woostundy]

@DozySun ……改造规模有点大啊

[ericls]

啊？ 还可以这么神奇直接改？

[julyclyde]

你外边套的是 tornado web server 而不是 tornado web framework 吧？那就直接改 gevent monkey patch 就得了

[woostundy]

@julyclyde 嗯，其实改起来也快。

[loalj]

requests 库换成 tornado 自带的 async httpclient 试一试?

[DozySun]

如果不重度依赖 requests 可以用 tornado 的异步 httpclient
否则就是 concurrent.futures

[woostundy]

@loalj @DozySun
需要立刻返回 request 的结果，用异步 httpclient 的话，很难写吧？
回调怎么返回给 flask 的 response

[timonwong]

我不知道在 tornado 上跑 flask 有什么意义，跟用单个进程，什么 threading, gevent, eventlet 都不用跑有多大区别，有没有老司机出来指点一下？

[loalj]

@woostundy 大概像这样

```
@gen.coroutine
def async_response():
http_client = AsyncHTTPClient()
res = yield http_client.fetch(url)
return res
```

[woostundy]

@loalj 多谢，完了我试试

[Livid]

耗时可能会超过半秒的函数一律放进 rq 或者 celery 做异步处理。

[woostundy]

@loalj 不过 2.7 里没法在有 yield 的方法里再写 return ，应该是 yield res 吧？

[woostundy]

@Livid 需要即时返回 request 的结果， celery 没法解决吧？

[wwqgtxx]

你这种需求还是用 gunicorn 或者 uwsgi 包装一下吧

[loalj]

@woostundy raise gen.Return(res)

[woostundy]

@loalj 用 yield 也 OK~ 刚试了可行

[cloverstd]

@woostundy

@gen.coroutine
def long_time_function():
task_id = task_function.delay()
while True:
gen.sleep(0.1)
res = get_res_from(task_id)
if res:
raise gen.Return(res)