aiohttp-riak 0.0.1

示例

importasyncioimportaiohttpfromaiohttp_riakimportRiakHTTP,Bucketasyncdefriak_requests(client):bucket=Bucket(client,'example')# Secondary indexesindexes=[('example_bin','ex'),('example_int','1')]awaitbucket.put('key','val',[indexes[0]])awaitbucket.put('key2','val2',[indexes[1]])awaitbucket.put('key3','val3',indexes)keys=awaitbucket.keys()print('KEYS',keys)keys=awaitbucket.index('example_bin','ex')print('INDEX_BIN',keys)keys=awaitbucket.index('example_int','1')print('INDEX_INT',keys)print('GET',awaitbucket.get('key2'))print('DEL',awaitbucket.delete('key2'))print('GET',awaitbucket.get('key2'))print('BUCKETS',awaitbucket.buckets())print('PING',awaitclient.ping())props=awaitbucket.props()print('PROPS',props)loop=asyncio.get_event_loop()rh=RiakHTTP('127.0.0.1',loop=loop)content=loop.run_until_complete(riak_requests(rh))rh.close()

许可证

aiohttp_riakbsd许可证。

贡献者

当您提交第一个请求时，请按字母顺序添加您自己。