asyncmongo-orm 0.3.1

asyncmongo-orm is an 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


Product's homepage

Requirements:

· Python
· pymongo
· Tornado
· AsyncMongo