Redis pubsub non-blocking interface (With a thread).
Project Description
Blocking subscribe implementation of pyredis is annoying for some case. It is controllable with some technique, but here is a quick approach using a python thread.
Note: This implementation is good only for few situation.
Example
>>> import redis >>> redisc = redis.Redis() >>> import redispubsub >>> pubsub = redispubsub.RedisPubsub(redisc.pubsub()) >>> pubsub.subscribe('1') # You SHOULD subscribe before starting thread. >>> pubsub.start() # Start the router >>> pubsub.dequeue('1') {'pattern': None, 'type': 'subscribe', 'channel': '1', 'data': 1L} >>> redisc.publish('1', 'test') >>> pubsub.dequeue('1') # None returned >>> pubsub.dequeue('1') {'pattern': None, 'type': 'message', 'channel': '1', 'data': 'test'} >>> pubsub.dequeue('1') # None returned
Release history Release notifications
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Filename, size & hash SHA256 hash help | File type | Python version | Upload date |
---|---|---|---|
redis-pubsub-helper-0.1.1.tar.gz (1.9 kB) Copy SHA256 hash SHA256 | Source | None | May 28, 2013 |