我想实现一个基于龙卷风的Web服务,它可以为用户提供数据库查询服务。我使用pyodbc模块连接到数据库并执行查询。实际上,我发现打印查询结果需要很长时间。也就是说,如果我用下面的代码打印查询结果与Tornado和pyodbc的异步调用
while 1:
data = cursor.fetchone()
if not data: break
self.write(data + '\n')
self.flush()
和SQL命令是一样的东西
select * from <a large dummy table>
龙卷风,直到循环结束不打印查询结果。这需要很长时间。
我想使用龙卷风的非阻塞异步功能,使其他用户也能够使用Web服务,即使打印当前用户的查询请求的循环尚未完成。
所以我写的东西,如:
@tornado.web.asynchronous
def get(self):
try:
cnxn = pyodbc.connect(self.server, self.driver, self.table, self.uid, self.pwd)
except Exception, e:
print e
return
try:
self.cur = cnxn.execute(self.sql)
except Exception, e:
print e
return
self.wait_for_query(callback=self.async_callback(self.on_finish))
def wait_for_query(self, callback):
while 1:
data = self.cur.fetchone()
if not data: break
self.write(data)
self.flush()
callback()
def on_finish(self):
self.finish()
我看到这篇文章: Asynchronous COMET query with Tornado and Prototype ,知道我的解决办法是行不通的。但我当然不能使用add_timeout,因为我无法弄清楚迭代持续的时间。那么,我如何通过这个工作来实现我的目标呢?