用龙卷风处理标准输入


问题内容

如何侦听龙卷风循环中stdin上发生的事件?

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

在寻找时,我能找到的最相似的东西是处理外部产生的过程的流。但是,这不是我想要的:我想处理 当前 进程的I / O流,即具有Web服务器的I / O流。

从结构上讲,我的服务器几乎是“ hello-
world”龙卷风
,因此我们可以以此为基础建立示例。我只需要添加一个stdin处理程序。


问题答案:

您可以add_handlerIOLoop实例上使用方法来监视上的事件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()