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

Merge pull request #90 from dervomsee/patch-1

Browse Source
This commit is contained in:
bohdan-s
2022-11-17 19:42:04 +11:00
committed by GitHub
parent 86b8b4577b 260f40443f
commit 03e3e6a3bd
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
SunGather/exports/influxdb.py
+4 -3
View File
@@ -60,9 +60,10 @@ class export_influxdb(object):
if not inverter.validateLatestScrape(measurement['register']): if not inverter.validateLatestScrape(measurement['register']):
logging.error(f"InfluxDB: Skipped collecting data, {measurement['register']} missing from last scrape") logging.error(f"InfluxDB: Skipped collecting data, {measurement['register']} missing from last scrape")
return False return False
sequence.append(f"{measurement['point']},inverter={inverter.getInverterModel(True)} {measurement['register']}={inverter.getRegisterValue(measurement['register'])}") if type(inverter.getRegisterValue(measurement['register'])) is str:
logging.debug(f'InfluxDB: Sequence; {sequence}') 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']))))
try: try:
self.write_api.write(self.influxdb_config['bucket'], self.client.org, sequence) self.write_api.write(self.influxdb_config['bucket'], self.client.org, sequence)
except Exception as err: except Exception as err: