Asyncmongo-ORM

Asyncmongo-ORM is a object-relation mapping for asyncmongo. AsyncMongo is an asynchronous library for accessing mongo which is built on the tornado ioloop.

asyncmongoorm is currently in version 0.2.0 and supports the following features:

• Map an collection
• Map fields of type (object_id, object, list, boolean, datetime, integer, string)
• Session facade to connection client
• Support to find, find_one, count, sum, geo_near and command
• Signals for pre_save, post_save, pre_remove, post_remove, pre_update, post_update

Installation

Installing: pip install asyncmongoorm

Usage

save, update, remove, etc...

from asyncmongoorm.collection import Collection
from asyncmongoorm.session import Session
from asyncmongoorm.field import StringField, ObjectIdField, BooleanField, DateTimeField

from datetime import datetime
import tornado.web
from tornado import gen

# create a new collection
class User(Collection):

    # collection name
    __collection__ = "user"
    
    # map fields
    _id = ObjectIdField()
    name = StringField()
    active = BooleanField()
    created = DateTimeField()
    
# create asyncmongo session client
Session.create('localhost', 27017, 'asyncmongo_test') 

class Handler(tornado.web.RequestHandler):

    @tornado.web.asynchronous
    @gen.engine
    def get(self):
        user = User()
        user.name = "User name"
        user.active = True
        user.created = datetime.now()

        yield gen.Task(user.save)

        # update date
        user.name = "New name"
        yield gen.Task(user.update)

        # find one object
        user_found = yield gen.Task(User.objects.find_one, user._id)
        
        # find many objects
        new_user = User()
        new_user.name = "new user name"
        new_user.user.active = True
        new_user.created = datetime.now()
        
        users_actives = yield gen.Task(User.objects.find, {'active': True})
        
        users_actives[0].active = False
        yield gen.Task(users_actives[0].save)

        # remove object
        yield gen.Task(user_found.remove)

signals

from asyncmongoorm.collection import Collection
from asyncmongoorm.session import Session
from asyncmongoorm.field import StringField, ObjectIdField, BooleanField, DateTimeField
from asyncmongoorm.signal import pre_save, receiver
from bson import ObjectId

import tornado.web
from tornado import gen

class User(Collection):
    __collection__ = "user"

    _id = ObjectIdField()
    name = StringField()
    active = BooleanField()
    created = DateTimeField()

@receiver(pre_save, User)
def set_object_id(sender, instance):
    if not instance._id:
        instance._id = ObjectId()

# create asyncmongo session client
Session.create('localhost', 27017, 'asyncmongo_test') 

class Handler(tornado.web.RequestHandler):

    @tornado.web.asynchronous
    @gen.engine
    def get(self):
        user = User()
        user.name = "User name"
        user.active = True
        user.created = datetime.now()

        yield gen.Task(user.save)

For more examples, view functional tests

Requirements

The following three python libraries are required

• pymongo version 1.9+ for bson library
• tornado
• asyncmongo

Issues

Please report any issues via github issues