面向对象的aioredis包装器。
redisobjects的Python项目详细描述
Redisobjects[aio Redis]的简单包装器(https://github.com/aio-libs/aioredis),为Python 3.6+中的Redis提供一个干净的面向对象接口的异步功能redisobjects
```
examples
--
>演示如何使用原子(定义为单键值对)的示例:
``python
``import redisobjects
import asyncio
async def main(loop):
redis=await redisobjects.connect('redis://localhost',loop=loop)
atom=redis.atom('example.atom')
print(await atom.get())
await atom.set('bla')
print(await atom.get())
await atom.remove()
print(await atom.get())
redis.close()
loop=asyncio.get_event_loop()
loop.run直至完成(main(loop))
loop.close()
```
列表:
``python
import redisobjects
import asyncio
async def main(循环):
redis=await redisobjects.connect('redis://localhost'loop=loop)
example_list=redis.list('example.list')
打印(等待example_list.list())
等待example_list.push_right('b')
等待example_list.push_right('c')
打印(等待example_list.list())
等待example_list.push_left('a')
打印(等待example_list.list())
等待示例_list.pop\u left()
wawait示例_list.pop\u left()
print(wawait示例_list.list())
wait示例_list.pop\u left()
print(wawait示例_list.list())
redis.close()
loop=asynciio.get\u event\u loop()
>loop.run直至完成(主(环)运行_unticomplete(主(环))
loop.cloop()
>loop.close()
`
`
使用一个dict/map:
`` python
导入redisobjects
导入asyncio
async def main(loop):
redis=await redisobjects.connect('redis://localhost',loop=loop)
d=redis.dict('example.dict')
打印(dict(await d.items())
等待d.set('a',1')
打印(dict(await d.items())
等待d.set('b',,'2')
打印(dict(await d.items())
等待d.set('c','3')
打印(dict(await d.items())
等待d.remove('a''b')
print(dict(await d.items())
await d.remove('c')
print(dict(await d.items())
redis.close()
loop=asyncio.getu event\u loop()
loop.run直至完成(main(loop))
loop.close()
``````>br/>
python
`` python
impimport redisobjects
>导入asyncio
async def main(loop):
redis=await redisobjects.connect('redis://localhost',loop=loop)
list=redis.list('example.list')
atom=redis.atom('example.atom')
tx=redis.create_transaction()
await list.push_right('a','b',tx=tx
await atom.set('a',,tx=tx)
打印(await list.list())
打印(await atom.get())
等待tx.commit()
打印(await list.list())
打印(await atom.get())
清理
等待列表。删除('a')
等待列表。删除('b')
等待atom.remove()
redis.close()
循环=asyncio.get_event_loop()
loop.run_until_complete(main(loop))
loop.close()
````
```
examples
--
>演示如何使用原子(定义为单键值对)的示例:
``python
``import redisobjects
import asyncio
async def main(loop):
redis=await redisobjects.connect('redis://localhost',loop=loop)
atom=redis.atom('example.atom')
print(await atom.get())
await atom.set('bla')
print(await atom.get())
await atom.remove()
print(await atom.get())
redis.close()
loop=asyncio.get_event_loop()
loop.run直至完成(main(loop))
loop.close()
```
列表:
``python
import redisobjects
import asyncio
async def main(循环):
redis=await redisobjects.connect('redis://localhost'loop=loop)
example_list=redis.list('example.list')
打印(等待example_list.list())
等待example_list.push_right('b')
等待example_list.push_right('c')
打印(等待example_list.list())
等待example_list.push_left('a')
打印(等待example_list.list())
等待示例_list.pop\u left()
wawait示例_list.pop\u left()
print(wawait示例_list.list())
wait示例_list.pop\u left()
print(wawait示例_list.list())
redis.close()
loop=asynciio.get\u event\u loop()
>loop.run直至完成(主(环)运行_unticomplete(主(环))
loop.cloop()
>loop.close()
`
`
使用一个dict/map:
`` python
导入redisobjects
导入asyncio
async def main(loop):
redis=await redisobjects.connect('redis://localhost',loop=loop)
d=redis.dict('example.dict')
打印(dict(await d.items())
等待d.set('a',1')
打印(dict(await d.items())
等待d.set('b',,'2')
打印(dict(await d.items())
等待d.set('c','3')
打印(dict(await d.items())
等待d.remove('a''b')
print(dict(await d.items())
await d.remove('c')
print(dict(await d.items())
redis.close()
loop=asyncio.getu event\u loop()
loop.run直至完成(main(loop))
loop.close()
``````>br/>
python
`` python
impimport redisobjects
>导入asyncio
async def main(loop):
redis=await redisobjects.connect('redis://localhost',loop=loop)
list=redis.list('example.list')
atom=redis.atom('example.atom')
tx=redis.create_transaction()
await list.push_right('a','b',tx=tx
await atom.set('a',,tx=tx)
打印(await list.list())
打印(await atom.get())
等待tx.commit()
打印(await list.list())
打印(await atom.get())
清理
等待列表。删除('a')
等待列表。删除('b')
等待atom.remove()
redis.close()
循环=asyncio.get_event_loop()
loop.run_until_complete(main(loop))
loop.close()
````