Python + Redis + PubSub

python_redis_publish.py

from python_redis_pubsub import TestPubsub
import time

if __name__ == "__main__":
    test = TestPubsub()
    print test.publish('test01', time.time())

python_redis_pubsub.py

import redis


class TestPubsub(object):

    def __init__(self):
        self._conn = redis.StrictRedis(connection_pool=redis.ConnectionPool())
        self._pubsub = self._conn.pubsub()

    def subscribe(self, key):
        return self._pubsub.subscribe(key)

    def publish(self, key, value):
        return self._conn.publish(key, value)

    def listen(self):
        return self._pubsub.listen()

python_redis_subscribe.py

from python_redis_pubsub import TestPubsub

if __name__ == "__main__":
    test = TestPubsub()
    test.subscribe('test01')

    for item in test.listen():
        print item