Revision 636530346532 () - Diff

Link to this snippet: https://friendpaste.com/1RVvKLPLNlVql9oyW06qZ0
Embed:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
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"}]}',) - {}