(tornado を使用して) 大きなデータを低速のクライアントに転送し、転送されたデータの量を出力するとします。この目的のために、次の簡単なコードを書きました。
from tornado import web, ioloop, gen
class MainHandler(web.RequestHandler):
@web.asynchronous
@gen.engine
def get(self):
print '( start'
try:
for i in xrange(100):
self.write('*' * 100000) # write ~100KB of data
yield gen.Task(self.flush) # wait for reciever to recieve
print '- wrote', i
finally:
print '| finally'
self.finish()
print ') finish'
application = web.Application([
(r"/", MainHandler),
])
application.listen(8888)
ioloop.IOLoop.instance().start()
しかし、このコードは期待どおりに動作しません。たとえば、次の単純なクライアントでは:
req = urlopen('http://127.0.0.1:8888/')
sys.exit() # exit without reading response
サーバーはこれを出力します:
( start
- wrote 0
- wrote 1
- wrote 2
WARNING:root:Read error on 7: [Errno 104] Connection reset by peer
WARNING:root:error on read
Traceback (most recent call last):
File "/usr/local/lib/python2.7/dist-packages/tornado-2.4.1-py2.7.egg/tornado/iostream.py", line 361, in _handle_read
if self._read_to_buffer() == 0:
File "/usr/local/lib/python2.7/dist-packages/tornado-2.4.1-py2.7.egg/tornado/iostream.py", line 428, in _read_to_buffer
chunk = self._read_from_socket()
File "/usr/local/lib/python2.7/dist-packages/tornado-2.4.1-py2.7.egg/tornado/iostream.py", line 409, in _read_from_socket
chunk = self.socket.recv(self.read_chunk_size)
error: [Errno 104] Connection reset by peer
しかし、どちらfinally
もfinish
印刷されません。
どうしたの?!
アップデート:
on_connection_close
ハンドラーに実装すると、on_connection_close
コールバックが呼び出され、コンソールにエラーが出力されないことに気付きました。しかし、この機能は何の魔法でしょうか? RequestHandler
(私はすでに空のボディで定義しています)。
そしてより大きな答え: なぜ私のジェネレーターはclose
d ではないのですか? ガベージコレクションかどうか?PEP-342 は、どのような状況でも finally ブロックを実行する必要があると述べています。