Skip to content

Instantly share code, notes, and snippets.

@dpnkrg
Forked from bamthomas/pub_sub_redis.py
Created October 30, 2018 12:23
Show Gist options
  • Save dpnkrg/1c713bc62bc7e03dd043df7ce43f8815 to your computer and use it in GitHub Desktop.
Save dpnkrg/1c713bc62bc7e03dd043df7ce43f8815 to your computer and use it in GitHub Desktop.
Pub/Sub redis python
from multiprocessing.process import Process
import time
import redis
def pub(myredis):
for n in range(10):
myredis.publish('channel','blah %d' % n)
time.sleep(5)
def sub(myredis, name):
pubsub = myredis.pubsub()
pubsub.subscribe(['channel'])
for item in pubsub.listen():
print '%s : %s' % (name, item['data'])
if __name__ == '__main__':
myredis = redis.Redis()
Process(target=pub, args=(myredis,)).start()
Process(target=sub, args=(myredis,'reader1')).start()
Process(target=sub, args=(myredis,'reader2')).start()
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment