reset if cannot write to influx?

davis_decode.py

@@ -5,7 +5,7 @@ try:
 except:
     _DEBUG = True
 
-def send_to_influx(host, port, db, user, password, davis_unit_id, wind, measurement, name, value, tags):
+def send_to_influx(host, port, db, user, password, davis_unit_id, wind, measurement, name, value, tags, rssi, lqi):
     post = "http://{}:{}/write?db={}".format(host, port, db)
     if _DEBUG:
         print(b"SENDING TO: {}".format(post))
@@ -21,13 +21,15 @@ def send_to_influx(host, port, db, user, password, davis_unit_id, wind, measurem
     else:
         for tag in tags.keys():
             measurement = "{},{}={}".format(measurement, tag, tags[tag])
-        data = "{_measure},davis_id={_davis_id} {_name}={_value}\n wind,type=speed,davis_id={_davis_id} value={_speed}\n wind,type=direction,davis_id={_davis_id} value={_direction}".format(
+        data = "{_measure},davis_id={_davis_id} {_name}={_value}\n wind,type=speed,davis_id={_davis_id} value={_speed}\n wind,type=direction,davis_id={_davis_id} value={_direction}\n signal,type=rssi,davis_id={_davis_id} value={_rssi}\n signal,type=lqi,davis_id={_davis_id} value={_lqi}".format(
             _measure=measurement,
             _name=name,
             _value=value,
             _davis_id = davis_unit_id,
             _speed=wind['speed'],
-            _direction=wind['direction'])
+            _direction=wind['direction'],
+            _rssi=rssi,
+            _lqi=lqi)
     if _DEBUG:
         print(b"POST_DATA: {}".format(data))
     try:

main.py

@@ -3,7 +3,6 @@ import davis_decode
 import utime
 import WiFi
 import machine
-import micropython
 gc.collect()
 
 DEBUG = True
@@ -79,7 +78,9 @@ while True:
                 decoder.measurement,
                 decoder.name,
                 decoder.value,
-                decoder.tags)
+                decoder.tags,
+                davis.rssi,
+                davis.lqi)
         except Exception as e:
             #raise e
             if _DEBUG:
@@ -91,8 +92,8 @@ while True:
                 print(b"DATA SEND: {}".format(data_sent.status_code))
             else:
                 print(b"DATA SEND FAIL: {}".format(data_sent))
-                if data_sent[0] == -2:
-                    machine.reset()
+                #if data_sent[0] == -2:
+                machine.reset()
         interpacket_time = 0
     else:
         interpacket_time += 1