CouchDB client built on top of aiohttp.
Current status: beta. aiocouchdb has all CouchDB API implements up to 1.6 release. However, it may lack of some usability and stability bits, but work is in progress. Feel free to send pull request or open issue if you find something that should be fixed.
Also don't miss the docs: http://aiocouchdb.readthedocs.org/en/latest/
import sys
import asyncio
from aiocouchdb import Server
@asyncio.coroutine
def go(url):
server = Server(url)
# multi-session workflow
admin = yield from server.session.open('admin', 's3cr1t')
user = yield from server.session.open('user', 'pass')
admin_info = yield from server.session.info(auth=admin)
user_info = yield from server.session.info(auth=user)
print('admin:', admin_info)
print('user:', user_info)
# db_updates is admin only resource
feed = yield from server.db_updates(feed='continuous', auth=admin,
heartbeat=False, timeout=10000)
while True:
event = yield from feed.next()
if event is None: # feed exhausted
break
dbname = event['db_name']
# want to use raw queries? that's easy
resp = yield from server.resource.get(dbname, auth=user)
if resp.status == 403:
# ignore Forbidden errors
continue
# but respect everyone else
yield from resp.maybe_raise_error()
dbinfo = yield from resp.json()
print(dbinfo)
# close sessions
assert {'ok': True} == (yield from server.session.close(auth=admin))
assert {'ok': True} == (yield from server.session.close(auth=user))
if __name__ == '__main__':
if '--iocp' in sys.argv:
from asyncio import events, windows_events
sys.argv.remove('--iocp')
el = windows_events.ProactorEventLoop()
events.set_event_loop(el)
loop = asyncio.get_event_loop()
loop.run_until_complete(go('http://localhost:5984'))BSD