ElixirForge/SunGather
3
0
Fork 0
mirror of https://github.com/alexhopeoconnor/SunGather.git synced 2026-10-04 02:48:12 +10:00
Code Issues Packages Projects Releases Wiki Activity

refactors #90

Browse Source
This commit is contained in:
Michael Kotten
2022-11-17 10:09:43 +01:00
parent 03e3e6a3bd
commit 0601a1d320
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
SunGather/exports/influxdb.py
+6 -6
View File
@@ -57,13 +57,13 @@ class export_influxdb(object):
sequence = []
for measurement in self.influxdb_measurements:
if not inverter.validateLatestScrape(measurement['register']):
logging.error(f"InfluxDB: Skipped collecting data, {measurement['register']} missing from last scrape")
register = measurement['register']
if not inverter.validateLatestScrape(register):
logging.error(f"InfluxDB: Skipped collecting data, {register} missing from last scrape")
return False
if type(inverter.getRegisterValue(measurement['register'])) is str:
sequence.append(influxdb_client.Point(measurement['point']).tag("inverter", inverter.getInverterModel(True)).field(measurement['register'], inverter.getRegisterValue(measurement['register'])))
else:
sequence.append(influxdb_client.Point(measurement['point']).tag("inverter", inverter.getInverterModel(True)).field(measurement['register'], float(inverter.getRegisterValue(measurement['register']))))
value = inverter.getRegisterValue(register) if type(inverter.getRegisterValue(register)) is str else float(inverter.getRegisterValue(register))
sequence.append(influxdb_client.Point(measurement['point']).tag("inverter", inverter.getInverterModel(True)).field(register, value))
try:
self.write_api.write(self.influxdb_config['bucket'], self.client.org, sequence)
except Exception as err: