python使用异步redis--aioredis,asynio_redis,aredis

安装

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())

未完待续···

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。