Example tornado coroutines that asynchronously save and retrieve document from a CouchDB

example_async_tornado-couchdb.py

# -*- coding: utf-8 -*-
import couch
from tornado import ioloop, gen


def _setup(db_name="test"):
    return couch.AsyncCouch(db_name)


@gen.coroutine
def save_user(db, user):
    result = yield db.save_doc(user)
    raise gen.Return(result)


@gen.coroutine
def get_user(db, user_id):
    try:
        result = yield db.get_doc(user_id)
        raise gen.Return(result)
    except couch.NotFound:
        print('Document not found')


@gen.coroutine
def main():
    user = {"name": "John"}
    db = _setup()
    new_user = yield save_user(db, user)
    found_user = yield get_user(db, new_user["id"])
    print user
    print db
    print new_user
    print found_user 


if __name__ == "__main__":
    ioloop.IOLoop().run_sync(main)