如何在龍捲風中執行對redis的異步寫入

Question

感謝this post，我嘗試了異步驅動程序tornado-redis。從演示（Github example）中可以看出，如何進行異步獲取使用這個庫，但我不清楚如果這些集合也是異步的（它們有回調函數）。

因此，如果可能的話，使用tornado-redis進行異步寫入的正確方法是什麼？它會是這樣的：

@tornado.web.asynchronous 
@tornado.gen.engine 
def post(self): 
    ... 
    yield tornado.gen.Task(t.set,'key', 'value') 

Answer 1

看看tornado-redis的代碼。 Client.set方法有以下defenition：

def set(self, key, value, callback=None): 
    self.execute_command('SET', key, value, callback=callback) 

所以，是的，它需要回調，可與gen.Task使用。

正確的方式來寫異步：你在問題中所述

1. 方式，使用gen。
2. 方式，在github例子中有描述。從GitHub

例子：

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

def on_set(result): 
    log.debug("set result: %s" % result) 

c.set('foo', 'Lorem ipsum #1', on_set) 
c.set('bar', 'Lorem ipsum #2', on_set) 
c.set('zar', 'Lorem ipsum #3', on_set) 

與根模塊單獨的類：

class MyRedisWrapper(object): 
    @gen.engine 
    def set(self, key, value): 
     yield tornado.gen.Task(t.set, key, value) 

r = MyRedisWrapper() 

class MyHandler(tornado.web.RequestHandler): 
    def get(self): 
     r.set('key', 'value') #It will work, but not sure about efficiency.