Friendpaste

--- Revision None
+++ Revision 636530346532
@@ -0,0 +1,32 @@
+from couchdbkit import Server
+from couchdbkit.consumer import Consumer
+from time import sleep
+
+from gevent import monkey
+monkey.patch_all()
+import gevent
+
+def print_event(*args, **kwargs):
+	print('EVENT: %s - %s' % (args, kwargs))
+
+s  = Server(uri='http://localhost:5984')
+db = s.get_or_create_db('a_test_db')
+
+
+c = Consumer(db, backend="gevent")
+
+c.wait_async(print_event, heartbeat=True)
+while True:
+    try:
+        gevent.sleep(0.1)
+    except (KeyboardInterrupt, SystemExit):
+        break
+        
+
+
+result : 
+
+
+$ python test.py 
+EVENT: ('{"seq":3,"id":"d1eca14fb05613c5be30b518c4000768","changes":[{"rev":"3-825cb35de44c433bfb2df415563a19de"}]}',) - {}
+EVENT: ('{"seq":4,"id":"d1eca14fb05613c5be30b518c4000c66","changes":[{"rev":"1-967a00dff5e02add41819138abb3284d"}]}',) - {}
a	b
	0	+	from couchdbkit import Server
	0	+	from couchdbkit.consumer import Consumer
	0	+	from time import sleep
	0	+
	0	+	from gevent import monkey
	0	+	monkey.patch_all()
	0	+	import gevent
	0	+
	0	+	def print_event(args, *kwargs):
	0	+	print('EVENT: %s - %s' % (args, kwargs))
	0	+
	0	+	s = Server(uri='http://localhost:5984')
	0	+	db = s.get_or_create_db('a_test_db')
	0	+
	0	+
	0	+	c = Consumer(db, backend="gevent")
	0	+
	0	+	c.wait_async(print_event, heartbeat=True)
	0	+	while True:
	0	+	try:
	0	+	gevent.sleep(0.1)
	0	+	except (KeyboardInterrupt, SystemExit):
	0	+	break
	0	+
	0	+
	0	+
	0	+	result :
	0	+
	0	+
	0	+	$ python test.py
	0	+	EVENT: ('{"seq":3,"id":"d1eca14fb05613c5be30b518c4000768","changes":[{"rev":"3-825cb35de44c433bfb2df415563a19de"}]}',) - {}
	0	+	EVENT: ('{"seq":4,"id":"d1eca14fb05613c5be30b518c4000c66","changes":[{"rev":"1-967a00dff5e02add41819138abb3284d"}]}',) - {}
...