3,430
edits
Changes
From Pumping Station One
→Communication
sensor = context.socket(zmq.SUB)
sensor = context.socket(zmq.SUB)
sensor.connect("tcp://sensor.tld:5556")
sensor.connect("tcp://sensor.tld:5556")
sensor.setsockopt(zmq.SUBSCRIBE, b"dot.delimited.filter")
topic, message = sensor.recv_multipart()
topic, message = sensor.recv_multipart()
data = json.loads(message)
data = json.loads(message)
