redis_gevent_pubsub.py

# coding: utf-8

import gevent.monkey

gevent.monkey.patch_all()

import os
import redis
import gevent


REDIS_URL = os.environ['REDIS_URL']
rds = redis.StrictRedis.from_url(REDIS_URL)
psobj = rds.pubsub()
channel = 'channel:1'


def do_pub():
    rds.publish(channel, 'a string')


def do_sub():
    psobj.subscribe(channel)
    for i in psobj.listen():
        # on connect: {'pattern': None, 'type': 'subscribe', 'channel': 'channel:1', 'data': 1L}
        # on new message: {'pattern': None, 'type': 'message', 'channel': 'channel:1', 'data': 'a string'}
        print('get msg', i, type(i['data']), repr(i['data']))
        gevent.sleep(0)
        print('waiting')


gevent.spawn(do_sub)


while True:
    gevent.sleep(3)
    do_pub()