YuruC3/MD1200
1
0
Fork 0
Code Issues 3 Pull Requests Actions Packages Projects Releases Wiki Activity

Added error catching for KeyError for Influx.

Browse Source
This commit is contained in:
YuruC3 2025-07-16 17:53:18 +02:00
parent 1f96e10f76
commit 978dd0dc5d
1 changed files with 17 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
PC_CONTROL_CODE/dockerInflux/mainDocker.py
View File

@ -30,7 +30,7 @@ TEMPSETING = bool(os.getenv("TEMPSETING", True))
PROCESSTEMPWAITTIME = float(os.getenv("PROCESSTEMPWAITTIME", 0.75)) PROCESSTEMPWAITTIME = float(os.getenv("PROCESSTEMPWAITTIME", 0.75))
BACKOFFTIME = float(os.getenv("BACKOFFTIME", 0.1)) BACKOFFTIME = float(os.getenv("BACKOFFTIME", 5))
# INFLUXDB config # INFLUXDB config
# token = "apg1gysUeCcxdcRTMmosJTenbEppmUNi9rXlANDB2oNadBdWAu2GVTDc_q_dyo0iyYsckKaOvPRm6ba2NK0y_A==" # token = "apg1gysUeCcxdcRTMmosJTenbEppmUNi9rXlANDB2oNadBdWAu2GVTDc_q_dyo0iyYsckKaOvPRm6ba2NK0y_A=="
@ -195,18 +195,22 @@ def process_temps():
# ---LeData--- # ---LeData---
if fluxSending: if fluxSending:
# Prep InfluxDB data # Prep InfluxDB data
inflxdb_Data_To_Send = ( try:
influxdb_client.Point(f"{measurement}-script") inflxdb_Data_To_Send = (
.tag("MACHINE", MACHINE_TAG) influxdb_client.Point(f"{measurement}-script")
.tag("LOCATION", LOCATION) .tag("MACHINE", MACHINE_TAG)
.field("Backplane1", MDict["bp1"]) .tag("LOCATION", LOCATION)
.field("Backplane2", MDict["bp2"]) .field("Backplane1", MDict["bp1"])
.field("SASIntModule0", MDict["sim0"]) .field("Backplane2", MDict["bp2"])
.field("SASIntModule1", MDict["sim1"]) .field("SASIntModule0", MDict["sim0"])
.field("Expander0", MDict["exp0"]) .field("SASIntModule1", MDict["sim1"])
.field("Expander1", MDict["exp1"]) .field("Expander0", MDict["exp0"])
.field("Average", MDict["avg"]) .field("Expander1", MDict["exp1"])
) .field("Average", MDict["avg"])
)
except KeyError:
time.sleep(BACKOFFTIME)
continue
# Prep/append data # Prep/append data
inflxdb_LeData.append(inflxdb_Data_To_Send) inflxdb_LeData.append(inflxdb_Data_To_Send)