redis.py 文件源码

def get_key(key, callback):
    async def wrapper():
        with await connection as redis:
            value = await redis.get(key)
        try:
            callback(value.decode())
        except:
            callback(value)
    asyncio.ensure_future(wrapper())