import zmq,json

ctx = zmq.Context()
sub = ctx.socket(zmq.SUB)
sub.connect('tcp://127.0.0.1:7777')
sub.setsockopt(zmq.SUBSCRIBE,'')

while True:
    id,data = sub.recv_multipart()
    try:
        data = json.parses(data)
    except:
        data = str(data)
    print(data,id)

sub.close()
ctx.term()