python-redisRedis pubsub listen example
This is messages listener that subscribes to specified channel and waits for messages infinitely:
r = redis.Redis()
q = r.pubsub()
q.subscribe('test')
for m in q.listen():
print(m)ctrl + credis.Redisconnect to Redis server | r.pubsub()creates pubsub instance |
subscribesubscribe to specified channel | 'test'name of the channel to subscribe to |
q.listenwill wait for and iterate through messages being published | |
Usage example
import redis
r = redis.Redis()
q = r.pubsub()
# assume someone will publish something to this channel
q.subscribe('test')
for m in q.listen():
print(m)output
{'type': 'subscribe', 'pattern': None, 'channel': b'test', 'data': 1}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'hi'}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'hello'}
...Related
More of Python Redis
- Count keys in Redis
- Clear all keys in Redis
- Iterate through Redis keys
- Set expiration (TTL) for Redis key
- Check if key exists in Redis
- Get list (all elements) from Redis
- Redis zadd example - adds element to sorted set
- Decode bytes obtained from Redis to string
- Search keys by pattern in Redis
- Get value from Redis key
See more codes...