j2labs · July 18, 2011 04:31 · Jul 18, 2011 · Jul 18, 2011
diff --git a/gistfile1.py b/gistfile1.py
@@ -6,7 +6,6 @@
 
 import eventlet
 pymongo = eventlet.import_patched('pymongo')
-from pymongo.errors import AutoReconnect
 
 ### Setup database connection
 dbc = pymongo.Connection()

diff --git a/gistfile1.py b/gistfile1.py
@@ -0,0 +1,24 @@
+#!/usr/bin/env python
+
+###
+### Concurrent pymongo inserts
+###
+
+import eventlet
+pymongo = eventlet.import_patched('pymongo')
+from pymongo.errors import AutoReconnect
+
+### Setup database connection
+dbc = pymongo.Connection()
+db = dbc.test
+
+### Prepare concurrent resources
+pool = eventlet.GreenPool(1000)
+
+def do(*args, **kwargs):
+    db.test_coll.insert(*args)
+    dbc.end_request()
+
+for i in xrange(1000):
+    pool.spawn_n(do, {'num': i})
+pool.waitall()