面向对象的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()
````



欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
java如何在springboot mongodata中使用$in运算符   多线程从等待线程Java释放资源   选择的java DropdownChoice与模型值不同,在ajax更新时更改   java在缓存spring中存储值   java在包资源管理器中突出显示文件   java将double[]转换为不可变列表的成本更低的方法   java Joda DateTimeFormat根据默认语言环境切换“MM”和“dd”的位置   ElasticSearch中的java嵌套搜索不起作用?   java SpringBoot@Scheduled Cron表达式在两个任务之间产生轻微延迟?   Spring应用程序中Tomcat mysql连接池的java动态选择目录   未为modal中的前两个字段发送java密钥   java如何在处理过程中使用循环排列打印的数字?i、 从10秒到100秒的e.x和y轴   java如何使用@ManyToMany审核@JoinTable   java如何防止JSESSIONID显示在URL中   JavaSpringSecurity5Always302