HTTP Riak connector for aiohttp
Project description
aiohttp_riak
riakhttp protocol implementation for aiohttp.web.
Example
import asyncio
import aiohttp
from aiohttp_riak import RiakHTTP, Bucket
async def riak_requests(client):
bucket = Bucket(client, 'example')
# Secondary indexes
indexes = [
('example_bin', 'ex'),
('example_int', '1')
]
await bucket.put('key', 'val', [indexes[0]])
await bucket.put('key2', 'val2', [indexes[1]])
await bucket.put('key3', 'val3', indexes)
keys = await bucket.keys()
print('KEYS', keys)
keys = await bucket.index('example_bin', 'ex')
print('INDEX_BIN', keys)
keys = await bucket.index('example_int', '1')
print('INDEX_INT', keys)
print('GET', await bucket.get('key2'))
print('DEL', await bucket.delete('key2'))
print('GET', await bucket.get('key2'))
print('BUCKETS', await bucket.buckets())
print('PING', await client.ping())
props = await bucket.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()
License
aiohttp_riak BSD license.
CHANGES
0.0.1 (2016-02-03)
Init release
Credits
aiohttp_riak is written by Veniamin Gvozdikov.
Contributors
Please add yourself here alphabetically when you submit your first pull request.