Couchbase 的 Twisted API 无法与 Python Tornado 一起使用

我正在尝试使用 Couchbase 4.0 开发人员预览版运行 Tornado 服务器。

import tornado.web
import tornado.httpserver
import tornado.options
import tornado.ioloop
import tornado.websocket
import tornado.httpclient
from tornado import gen
import os.path
from tornado.options import define, options, parse_command_line
import time

#from couchbase.bucket import Bucket
from twisted.internet import reactor
from txcouchbase.bucket import Bucket

from couchbase.n1ql import N1QLQuery, N1QLError
from pprint import pprint

server = "x.x.x.x"
bucketname = "zips"

Connection = "couchbase://" + server + "/" + bucketname

bkt = Bucket(Connection)

class IndexHandler(tornado.web.RequestHandler):
    @tornado.web.asynchronous   
    def get(self):
        print "entered"
        query = "SELECT * FROM `zips` where pincode= '632014'"
        q = N1QLQuery(query)
        #self.bkt = bkt
        t0 = time.time()
        res = bkt.n1qlQueryAll(q)
        res.addCallback(self.on_ok)
        reactor.run()
        t1 = time.time()
        print t1-t0
        self.write("Hello World")

    def on_ok(self,response):
        print "LOl"
        for each in res:
            print each
        reactor.stop()
        self.finish()

handlers = [
    (r'/',IndexHandler),
]

if __name__ == "__main__":
    parse_command_line()
    # template path should be given here only unlike handlers
    app = tornado.web.Application(handlers, template_path=os.path.join(os.path.dirname(__file__), "templates"),
                                  static_path=os.path.join(os.path.dirname(__file__), "static"), cookie_secret="61oETzKXQAGaYdkL5gEmGeJJFuYh7EQnp2XdTP1o/Vo=", debug=True)
    http_server = tornado.httpserver.HTTPServer(app)
    http_server.listen(8888, address='0.0.0.0')
    tornado.ioloop.IOLoop.instance().start()

在我运行此命令后，由于某种原因，回调函数永远不会被调用。我找不到任何合适的文档，因此必须通过源代码来编写此内容。我仍然很困惑，因为我是异步编程的新手。有人可以告诉我哪里出了问题以及是否有更好的方法？

在异步编程中，您只想启动一个事件循环（例如IOLoop.start() or reactor.run()) 一次，在程序的顶部。你正在呼唤IOLoop.start()，所以不要调用reactor.run()您想要告诉 Twisted 使用 Tornado IOLoop 作为其反应器。导入前reactor, do

import tornado.platform.twisted
tornado.platform.twisted.install()
from twisted.internet import reactor

See http://www.tornadoweb.org/en/stable/twisted.html#twisted-on-tornado http://www.tornadoweb.org/en/stable/twisted.html#twisted-on-tornado了解更多。

完成此操作后，您可以调用扭曲库，而无需启动和停止反应器。