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'}
...