sonic数据库的异步python客户端
asonic的Python项目详细描述
asonic实现所有
Sonicapi
欢迎进行错误修复和api更改
安装
pip install asonic
API文档
用法
搜索频道
importasynciofromasonicimportClientfromasonic.enumsimportChannelsasyncdefmain():c=Client(host='127.0.0.1',port=1491,password='SecretPassword',max_connections=100)awaitc.channel(Channels.SEARCH.value)# or simply searchawaitc.query('collection','bucket','quick')=='user_id'awaitc.suggest('collection','bucket','br',1)=='brown'if__name__=='__main__':loop=asyncio.get_event_loop()loop.run_until_complete(main())
摄取通道
importasynciofromasonicimportClientfromasonic.enumsimportChannelsasyncdefmain():c=Client(host='127.0.0.1',port=1491)awaitc.channel(Channels.INGEST.value)# or simply ingestawaitc.push('collection','bucket','user_id','The quick brown fox jumps over the lazy dog')# Return b'OK'awaitc.pop('collection','bucket','user_id','The')# Return 1if__name__=='__main__':loop=asyncio.get_event_loop()loop.run_until_complete(main())
控制通道
importasynciofromasonicimportClientfromasonic.enumsimportChannels,Actionsasyncdefmain():c=Client(host='127.0.0.1',port=1491)awaitc.channel(Channels.CONTROL.value)# or simply controlawaitc.trigger(Actions.CONSOLIDATE)# or simply consolidate# Return b'OK'awaitingest.pop('collection','bucket','user_id','The')# Return 1if__name__=='__main__':loop=asyncio.get_event_loop()loop.run_until_complete(main())
欢迎加入QQ群-->： 979659372
推荐PyPI第三方库
- 热门话题
- java如何在href中将struts2文本字段的值作为参数传递？ java检查对象属性是否为空的最佳方法是什么？ java通过Maven使用Junit类别运行Cucumber测试 java如何在selenium Webdriver（Mac）中使用Robot类上传多个文件？ 如何用python绘制图形或将python转换为java和Matlab？ java Osgi捆绑包更新和ResourceBundle java使用流api将流<@Nullable T>转换为流<@NonNull T> java中EXCEL的平台无关连接字符串 JavaFX中的java表 java Jetty线程池和sun。HttpServer会话 JPA存储库bean的java Spring注入无法工作NullPointerException java从另一个Kubernetes作业触发Kubernetes 我的java netbeans抽奖计划需要帮助吗 泛型中的java有界类型无法扩展另一个有界类型 如果混合使用全局构建和概要文件构建，java cxfcodegenplugin会生成错误代码 封装SQL平台之间差异的java策略？