from random import randrange import time import zmq import logging TOPIC = 'USAGE' logging.basicConfig(level = logging.INFO) context = zmq.Context() socket = context.socket(zmq.PUB) socket.bind("tcp://*:5555") while True: data = randrange(100) socket.send_string("%s %d" % (TOPIC, data)) logging.info("Usage sensor send %d" % data) time.sleep(1)