Things Bus: Difference between revisions
From Pumping Station One
| Line 104: | Line 104: | ||
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) | ||
