MongoDB Pool for gevent and pymongo packages (Python)

2011-09-02T05:56:58-07:00

Python recipe 577490 by Andrey Nikishaev (gevent, mongodb, pymongo, python). Revision 2.

Wrote some simple implementation of pool for pymongo package under gevent coroutine library.

Base bug here was with pymongo.connection.Pool because in the original package it is thread-local, so when you spawn new greenlet and trying to get already open connection, it creates new connection because in this greenlet pool is empty. So if you will implement your own pool don’t forget about this.

Example of use:

# Create Pool. 
db = Mongo('test_db',10)
# Get connection from pool
conn = db.get_conn()
# Get raw connection for GridFS
raw_conn = conn.getDB

#Mongo is a singleton. So if you want to get connection in another part of application just type
db = Mongo()
conn = db.get_conn()

#Connection will get back to pool when context will be closed.

Observer Design Pattern for python gevent coroutine package (Python)

2010-12-08T08:33:30-08:00

Python recipe 577491 by Andrey Nikishaev (event, gevent, observer, python).

This is simple implementation of the observer design pattern. Acting as a registration hub, it fires events when requested. Also i have gevent.Timeout like interface in situations when you need to run event-method in the same greenlet. Example:

e = Observer()
ev = e.wait('kill')
try:
    gevent.sleep(3)
except FiredEvent:
    print 'Fired!'
else:
    print 'Not Fired!'
finally:
    ev.cancel()

But rememeber, if you are using subscribe method, event-method will be executed in another greenlet.

Popular recipes tagged "gevent"

MongoDB Pool for gevent and pymongo packages (Python)

Example of use:

Observer Design Pattern for python gevent coroutine package (Python)