Redis pubsub python

consumer.py

import redis
import time


def message_handler(message):
    print(time.time() - float(message['data']))


def run():
    r = redis.StrictRedis()
    p = r.pubsub()
    p.subscribe(**{'event': message_handler})
    thread = p.run_in_thread(sleep_time=0.001)
    try:
        thread.join()
    except:
        thread.stop()


if __name__ == '__main__':
    run()

producer.py

import redis
import sys
import time


def run():
    r = redis.StrictRedis()
    for i in range(1, 1000):
        r.publish('event', time.time())


if __name__ == '__main__':
    run()