面向对象的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如何将外部库(LIB)集成到grails项目中?   java 安卓:progressTintMode、安卓:secondaryProgressTintMode和安卓:progressDrawable做什么?   java获得了启动播放器的精确方向   java如何在布局/样式XML中设置状态栏着色颜色?   Java中的图形游戏未显示   java如何在WebSphere8.5.5中的我的JAAS自定义登录模块中使用SAML令牌属性值   使用jackson spring API解析嵌套json   java如何从用户请求中获取用户代理?   Netbeans 6.8中的java UI控件定位   java显示listgrid中两个表中的数据   java Google Cloud Bigtable客户端连接池   Vert中的java更改日志级别。通过添加一个配置文件   java调用构造函数是否意味着创建实例?   java getFrom()[0])中[0]用于获取邮件发件人地址的用法是什么   “继续”标志的java Gradle属性?   jakarta ee如何在java ee中创建GUID   java不兼容类型:无法将int转换为整数   java需要借助DefaultHandler的characters函数将XML数据读入安卓应用程序   java mapstruct将方法应用于列表中的所有对象