用龙卷风处理标准输入
问题内容:
如何侦听龙卷风循环中stdin上发生的事件?
特别是在龙卷风系统中,我想从标准输入中读取信息,对其作出反应,并在标准输入关闭时终止。同时,Tornado Web服务在同一进程上运行。
在寻找时,我能找到的最相似的东西是处理外部产生的过程的流。但是,这不是我想要的:我想处理 当前 进程的I / O流,即具有Web服务器的I / O流。
从结构上讲,我的服务器几乎是“ hello-
world”龙卷风
,因此我们可以以此为基础建立示例。我只需要添加一个stdin处理程序。
问题答案:
您可以add_handler
在IOLoop
实例上使用方法来监视上的事件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()