--bugs

[svn42.git] / sensorvalues-to-json-zmq.py

diff --git a/sensorvalues-to-json-zmq.py b/sensorvalues-to-json-zmq.py
index aec3fef..b6cd17c 100755 (executable)
--- 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