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

Error when writing to InfluxDB

Browse Source 
InfluxDB was returning erros. So I adapted the way of building the query.
This commit is contained in:
benni336
2022-01-20 12:53:23 +01:00
parent eb6dd1aa85
commit 87724a727b
1 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
SunGather/exports/influxdb.py
+10 -3
View File
@@ -50,9 +50,16 @@ class export_influxdb(object):
logging.info("InfluxDB: Skipped, Initial Configuration Failed") logging.info("InfluxDB: Skipped, Initial Configuration Failed")
return False return False
sequence = [] # Setting a Standard Measurement Name and Inverter as a tag for later filtering
# could be extended by using values from config.yaml or SerialNo or ...
# Maybe also better switch to p=influxdb_client.Point(xxx).Tag().Field()
sequence= f"measure1,inverter={inverter.get('device_type_code', 'unknown').replace('.','').replace('-','')} "
for measurement in self.measurements: for measurement in self.measurements:
sequence.append(f"{measurement.get('point')},inverter={inverter.get('device_type_code', 'unknown').replace('.','').replace('-','')} {measurement.get('register')}={inverter.get(measurement.get('register'))}") sequence += f"{measurement.get('register')}={inverter.get(measurement.get('register'),0)},"
# remove last ","
sequence=sequence[:-1]
logging.debug(f'InfluxDB: Sequence; {sequence}') logging.debug(f'InfluxDB: Sequence; {sequence}')
try: try:
self.write_api.write(self.bucket, self.client.org, sequence) self.write_api.write(self.bucket, self.client.org, sequence)
@@ -61,4 +68,4 @@ class export_influxdb(object):
logging.info("InfluxDB: Published") logging.info("InfluxDB: Published")
return True return True