Redis pubsub router
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
1 maintainer
Release files for redis-pubsub-helper 0.1.1
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| redis-pubsub-helper-0.1.1.tar.gz | 1.9 kB | Details |
Release files / redis-pubsub-helper-0.1.1.tar.gz
| Download URL | redis-pubsub-helper-0.1.1.tar.gz |
|---|---|
| Size | 1.9 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
cafae56de17eabc6934e1b3dfb69a4d13177480e6b221f84c06e1e3aabcb45f5
|
|
BLAKE2b-256 checksum How to use checksums |
14cf8cca0d05989edab8b5eca4e1c431b63494a6bd7ca8f30a5c014963875d37
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
