优雅地关闭Tornado流媒体请求

Question

我有一个TornadoRequestHandler和@Tornado.web.stream\u request\u body装饰器，允许对处理程序进行分块流式处理。

在允许流式传输之前，我需要执行身份验证和其他一些检查。我试图在CrisestHandler.prepare（）方法中实现这些，但是当我使用请求向处理程序传输数据时，检查失败，连接突然关闭，我看到一个异常：

requests.exceptions.ConnectionError:[Errno 32]管道破裂

我的方法如下：

def prepare(self):
    check = some_function()
    if not check:
        self.set_status(400)
        self.write('some error message')
        self.finish()
        return

如何确保请求正常关闭，以便在检查失败时向客户端返回错误消息？

Answer 1

在HTTP/1中很难优雅地处理这个问题。大多数客户机只是盲目地编写请求，在编写完整的请求之前不会寻找服务器的响应，因此阻止他们发送整个请求的唯一方法是突然关闭连接。

您想要的行为可以在一个名为100-继续的模糊HTTP功能中找到。如果客户端支持这一点，那么它将等待准备（）完成，以查看是否有错误，然后再上传请求。请求不支持此功能。如果在读取时传递expect_100_continue=True，则Tornado的默认HTTP客户端会这样做。