motor_demo.py

import motor.motor_asyncio
import asyncio

client = motor.motor_asyncio.AsyncIOMotorClient('localhost', 27017)
db = client['testDB']

async def do_insert(user, collection_name):
    document = {'user': user}
    result = await db[collection_name].insert_one(document);
    print('Added user %s' % user)

loop = asyncio.get_event_loop()
loop.run_until_complete(do_insert('john', 'testCollection'))
loop.run_until_complete(do_insert('maximo', 'testCollection'))
loop.run_until_complete(do_insert('phoenix', 'testCollection'))