0

我有一个简单的例子：

c = tornadoredis.Client()
c.connect()

class SourceHandler(tornado.web.RequestHandler):
@tornado.web.asynchronous
@tornado.gen.engine
def get(self):
    pipe = c.pipeline(transactional=True)
    pipe.zadd( 'test1'), 1212, "test" )
    pipe.zadd( 'test2'), 1212, "test" )
    .....
    pipe.zadd( 'testN'), 1212, "test" )
    res = yield tornado.gen.Task(pipe.execute)
    self.set_header('Content-Type', 'text/html')
    self.render("template.html", title="result")

此请求的时间 = N * zadd 操作的时间。

我可以减少这个请求的时间吗？

4

1 回答 1

1

管道请求是一种事务性请求，它要求其中的所有操作都作为原子单元执行。该语句 -res = yield tornado.gen.Task(pipe.execute)将等到所有zadd语句都被执行，直到它返回执行到您的 get(...) 函数。

您可以减少执行时间的唯一方法是删除gen.engine火灾并忘记模式中的位，尽管您将不再拥有任何响应信息。 

class SourceHandler(tornado.web.RequestHandler):
    @tornado.web.asynchronous
    def get(self):
        pipe = c.pipeline(transactional=True)
        pipe.zadd( 'test1'), 1212, "test" )
        pipe.zadd( 'test2'), 1212, "test" )
        ...
        pipe.execute()
        # of course you no longer have the response information...
        ...old code...
于 2012-05-23T13:14:28.517 回答