X-Git-Url: https://git.realraum.at/?p=svn42.git;a=blobdiff_plain;f=sensorvalues-to-json-zmq.py;h=b6cd17cb6f61981d6a86c8a527b59d25a8674a66;hp=aec3fef43dc5aada69724fecaab2f5faa657fbcf;hb=565b834fd55e0a145099a728c12493cf26c29362;hpb=24beb46159420e5fba929b328d045bf40e6ff433 diff --git a/sensorvalues-to-json-zmq.py b/sensorvalues-to-json-zmq.py index aec3fef..b6cd17c 100755 --- a/sensorvalues-to-json-zmq.py +++ b/sensorvalues-to-json-zmq.py @@ -255,6 +255,17 @@ if __name__ == "__main__": except Exception, e: logging.debug(e) + + for k in set(sensor_store.keys()).difference(set(uwscfg.zmq_subscribe.split(" "))): + del sensor_store[k] # del old sensordata of sensor we do not subscribe to + + for k in sensor_store.keys(): + try: + if len(sensor_store[k][0]) > 1: + sensor_cols_num_[k] = len(sensor_store[k][0]) -1 + except: + pass + while True: try: #Start zmq connection to publish / forward sensor data