orig.py - randomcrap - random crap programs of varying quality
 (HTM) git clone git://git.codemadness.org/randomcrap
 (DIR) Log
 (DIR) Files
 (DIR) Refs
 (DIR) README
 (DIR) LICENSE
       ---
       orig.py (1242B)
       ---
            1 # Code adapted from: http://htmwiki.nl/#!hackathon/realtime.md
            2 # https://ndovloket.nl/
            3 # http://data.ndovloket.nl/REALTIME.TXT
            4 # https://www.hackdeoverheid.nl/aan-de-slag-met-open-ov-data/
            5 #
            6 # Dependencies: python3, python3-zeromq, zeromq
            7 #
            8 # XML spec BISON: http://data.ndovloket.nl/docs/bison/haltestandaard/xsd/
            9 
           10 from gzip import GzipFile
           11 from io import BytesIO
           12 import zmq
           13 
           14 context = zmq.Context()
           15 
           16 subscriber = context.socket(zmq.SUB)
           17 subscriber.connect("tcp://pubsub.besteffort.ndovloket.nl:7658")
           18 #subscriber.setsockopt_string(zmq.SUBSCRIBE, "/RIG/KV6posinfo")
           19 #subscriber.setsockopt_string(zmq.SUBSCRIBE, "/RIG/KV17cvlinfo")
           20 
           21 subscriber.setsockopt_string(zmq.SUBSCRIBE, "/QBUZZ/KV15messages")
           22 subscriber.setsockopt_string(zmq.SUBSCRIBE, "/QBUZZ/KV6posinfo")
           23 subscriber.setsockopt_string(zmq.SUBSCRIBE, "/QBUZZ/KV17cvlinfo")
           24 
           25 while True:
           26     multipart = subscriber.recv_multipart()
           27     address = multipart[0]
           28     #contents = ''.join(str(multipart[1:]))
           29     contents = multipart[1:][0]
           30     #print('DEBUG ', contents)
           31     try:
           32         contents = GzipFile('','r',0,BytesIO(contents)).read()
           33         print('GZIP', address, str(contents))
           34     except:
           35         raise
           36         print('NOT ', address, contents)
           37 
           38 subscriber.close()
           39 context.term()