如何在 tornado.wsgi.WSGIContainer 中使用异步龙卷风 API？

Question

我尝试使用应该与异步操作一起使用的自定义 WSGIContainer：

from tornado import httpserver, httpclient, ioloop, wsgi, gen

@gen.coroutine
def try_to_download():
    response = yield httpclient.AsyncHTTPClient().fetch("http://www.stackoverflow.com/")
    raise gen.Return(response.body)


def simple_app(environ, start_response):
    res = try_to_download()

    print 'done: ', res.done()
    print 'exec_info: ', res.exc_info()

    status = "200 OK"
    response_headers = [("Content-type", "text/html")]
    start_response(status, response_headers)
    return ['hello world']


container = wsgi.WSGIContainer(simple_app)
http_server = httpserver.HTTPServer(container)
http_server.listen(8888)
ioloop.IOLoop.instance().start()

但这行不通。似乎应用程序不等待 try_to_download 函数结果。下面的代码也不起作用：

from tornado import httpserver, httpclient, ioloop, wsgi, gen


@gen.coroutine
def try_to_download():
    yield gen.Task(httpclient.AsyncHTTPClient().fetch, "http://www.stackoverflow.com/")


def simple_app(environ, start_response):

    res = try_to_download()
    print 'done: ', res.done()
    print 'exec_info: ', res.exc_info()

    status = "200 OK"
    response_headers = [("Content-type", "text/html")]
    start_response(status, response_headers)
    return ['hello world']


container = wsgi.WSGIContainer(simple_app)
http_server = httpserver.HTTPServer(container)
http_server.listen(8888)
ioloop.IOLoop.instance().start()

您知道为什么它不起作用吗？我使用的 Python 版本是 2.7。

附：你可能会问我为什么不想使用原生 tornado.web.RequestHandler。主要原因是我有自定义 python 库（WsgiDAV），它可以生成 WSGI 接口并允许编写自定义适配器，我可以使它们异步。

Answer 1

WSGI 不适用于异步。

一般来说，要等待 Tornado 协程完成的函数，函数本身必须是协程并且必须 yield 协程的结果：

@gen.coroutine
def caller():
    res = yield try_to_download()

当然，像simple_app 这样的 WSGI 函数不能是协程，因为 WSGI 不理解协程。 Bottle documentation 中对 WSGI 和 async 之间的不兼容有更彻底的解释。

如果您必须支持 WSGI，请不要使用 Tornado 的 AsyncHTTPClient，而是使用标准的 urllib2 或 PyCurl 之类的同步客户端。如果必须使用 Tornado 的 AsyncHTTPClient，请不要使用 WSGI。