context = zmq.Context()
subscriber = context.socket(zmq.SUB)
#subscriber.setsockopt_string(zmq.SUBSCRIBE, "/RET/EstimatedTimetableDelivery")
subscriber.setsockopt_string(zmq.SUBSCRIBE, "/RET/VehicleMonitoringDelivery")
while True:
multipart = subscriber.recv_multipart()
address = multipart[0]
contents = b''.join(multipart[1:])
try:
contents = GzipFile('','r',0,io.BytesIO(contents)).read()
print('GZIP', address, contents)
except:
raise
print('NOT ', address, contents)
subscriber.close()
context.term()
----------------------------------------------------------
Helaas werkt dit met de KV6 datastream wel, maar met deze niet. Heeft iemand misschien enig idee waarom?