python使用异步redis--aioredis，asynio

安装

pip install aioredis

例子：

import asyncio
import aioredis

loop = asyncio.get_event_loop()

async def run():
  conn = await aioredis.create_connection(('localhost', 6379), loop=loop)
  await conn.set('my_key', 'value')
  val = await.get('my_key')
  print(val)
  conn.close()
  await redis.wait_closed(run())

await.run_until_complete(run())

添加redis连接池：

import asyncio
import aioredis

loop = asyncio.get_event_loop()

async def run():
  pool = await aioredis.create_pool(('localhost', 6379), minsize=5, maxsize=10, loop=loop)
  with await pool as redis:
    await redis.set('my_key', 'value')
    print(await redis.get('my_key'))
  pool.close()
  await pool.wait_closed()

loop.run_until_complete(run())

未完待续···