在开发中,数据库是必不可少的, 因此这节主要来说一下常用的两种类型数据库,mysql和redis的简单使用

#tornadoredis这款api。
import tornadoredis
from tornado import gen
from tornado.concurrent import Future
pool = None
def init():
    global pool
    if not pool:
        CONNECTION_POOL = tornadoredis.ConnectionPool(max_connections=500, wait_for_available=True)
        pool = tornadoredis.Client(connection_pool=CONNECTION_POOL, selected_db=12) 
@gen.coroutine
    if pool:
@gen.coroutine
def batch(commands):
    assert pool is not None
    result = None
    try:
        pipe = pool.pipeline()
        for _cmd in commands:
            _op   = _cmd[0]
            _args = _cmd[1]
            if len(_cmd) > 2:
                _kwargs = _cmd[2]
            else:
                _kwargs = {}
            getattr(pipe, _op)(*args, **kwargs)
        result = yield gen.Task(pipe.execute)
    except Exception as e:
        print e
    raise Return(result)
def execute(cmd, *args, **kwargs):
    assert pool is not None
    f = Future()
    def onResult(result):
        f.set_result(result)
    result = None
    _func  = getattr(pool, cmd)
    _func(callback=onResult, *args, **kwargs)
    return f
#对redis的操作进行了统一封装,直接使用execute就可以, 将命令作为参数传递。多个命令的执行可以使用batch来执行, 使用pipe提高执行效率。