用龙卷风处理标准输入

Question

如何在 Tornado 循环中监听 stdin 上发生的事件？

特别是，在龙卷风系统中，我想从标准输入读取数据，对其做出反应，并在标准输入关闭时终止。同时，Tornado Web 服务也在同一个进程上运行。

在寻找这个时，我能找到的最相似的是处理外部产生的进程的流。但是，这不是我想要的：我想处理 current 进程的 i/o 流，即拥有 Web 服务器的进程。

在结构上，我的服务器几乎是hello-world tornado，所以我们可以以此为基础。我只需要添加一个标准输入处理程序。

Answer 1

您可以在IOLoop 实例上使用add_handler 方法来监视stdin 上的事件。

这是一个最小的工作示例：

from tornado.ioloop import IOLoop
from tornado.web import Application, RequestHandler
import sys

class MainHandler(RequestHandler):

    def get(self):

        self.finish("foo")

application = Application([
    (r"/", MainHandler),
])

def on_stdin(fd, events):

    content = fd.readline()

    print "received: %s" % content

if __name__ == "__main__":

    application.listen(8888)

    IOLoop.instance().add_handler(sys.stdin, on_stdin, IOLoop.READ)

    IOLoop.instance().start()