龙卷风流HTTP响应作为AsyncHTTPClient接收块

Question

我试图编写一个龙卷风请求处理程序，它生成异步HTTP请求，并在客户端从异步请求接收数据时将数据返回给客户端。不幸的是，我无法让龙卷风返回任何数据到客户端，直到它的所有异步HTTP请求都完成。

下面是我的请求处理程序的演示。

class StreamingHandler(web.RequestHandler):

    all_requested = False
    requests = []

    @web.asynchronous
    def get(self):

        http_client = httpclient.AsyncHTTPClient()
        self.write('some opening')

        big_request = httpclient.HTTPRequest(url='[some_big_request]', streaming_callback=self.on_chunk)
        small_request = httpclient.HTTPRequest(url='[some_small_request]', streaming_callback=self.on_chunk)

        self.requests.append(http_client.fetch(big_request, callback=self.on_response_complete))
        self.requests.append(http_client.fetch(small_request, callback=self.on_response_complete))

        self.all_requested = True

    def on_chunk(self, chunk):
        self.write('some chunk')
        self.flush()

    def on_response_complete(self, response):
        if self.all_requested and all(request.done() for request in self.requests):
            self.write('some closing')
            self.finish()

我希望对这个处理程序的GET请求最初返回文本“some opening”，然后很快为小请求返回“some chunk”，然后为大请求返回“some chunk”（可能多次），最后返回“some closing”，并关闭连接。相反，在建立连接之后，客户端会等待几秒钟，等待所有请求完成，然后在关闭之前立即接收所有HTTPResponse。

我该如何从龙卷风中获得我想要的行为？

提前谢谢！

Answer 1

用gen.coroutine装饰您的方法，并生成一个未来列表。下面是一个简单的例子：

from tornado import gen, web, httpclient

class StreamingHandler(web.RequestHandler):
    @web.asynchronous
    @gen.coroutine
    def get(self):
        client = httpclient.AsyncHTTPClient()

        self.write('some opening')
        self.flush()

        requests = [
            httpclient.HTTPRequest(
                url='http://httpbin.org/delay/' + str(delay),
                streaming_callback=self.on_chunk
            ) for delay in [5, 4, 3, 2, 1]
        ]

        # `map()` doesn't return a list in Python 3
        yield list(map(client.fetch, requests))

        self.write('some closing')
        self.finish()

    def on_chunk(self, chunk):
        self.write('some chunk')
        self.flush()

请注意，即使请求是“向后”生成的，第一个块仍将在大约一秒钟后被接收。如果同步发送，需要15秒。当您异步请求它们时，只需5分钟。