Mercurial > code > home > repos > mqtt_metrics
diff convert.py @ 6:bc2a93b306e9
port over the powermeter measurements
author | drewp@bigasterisk.com |
---|---|
date | Sat, 10 Aug 2024 23:03:57 -0700 |
parents | 8390d5d0d512 |
children | 2a507e679d0d |
line wrap: on
line diff
--- a/convert.py Sat Aug 10 23:02:51 2024 -0700 +++ b/convert.py Sat Aug 10 23:03:57 2024 -0700 @@ -1,6 +1,8 @@ ''' Note that these functions need to parse the message['payload'] into a float ''' +import json + converters = [] @@ -43,3 +45,31 @@ }], 'value': f_from_c(float(message['payload'])), }] + + +@topic(r'(tele/st-wall-power/SENSOR|tele/ki-fridge/SENSOR|tt-console-power/SENSOR)') +def poorly_named_sonoff_powermeter(message, topicGroups: tuple[str]) -> list[dict]: + energy = json.loads(message['payload'])['ENERGY'] + sensor = { + 'tele/st-wall-power/SENSOR': 'st_wall', + 'tele/ki-fridge/SENSOR': 'ki_fridge', + 'tt-console-power/SENSOR': 'tt_console', + }[topicGroups[0]] + return [{ 'name': 'powermeter_w', 'labels': [{'labelName': 'sensor', 'labelValue': sensor}], 'value': energy['Power'] }, + { 'name': 'powermeter_apparent_power_va', 'labels': [{'labelName': 'sensor', 'labelValue': sensor}], 'value': energy['ApparentPower'] }, + { 'name': 'powermeter_reactive_power_var', 'labels': [{'labelName': 'sensor', 'labelValue': sensor}], 'value': energy['ReactivePower'] }, + { 'name': 'powermeter_factor', 'labels': [{'labelName': 'sensor', 'labelValue': sensor}], 'value': energy['Factor'] }, + { 'name': 'powermeter_voltage_v', 'labels': [{'labelName': 'sensor', 'labelValue': sensor}], 'value': energy['Voltage'] }, + { 'name': 'powermeter_current_a', 'labels': [{'labelName': 'sensor', 'labelValue': sensor}], 'value': energy['Current'] } ] # yapf: disable + +@topic(r'(.*)-power/status/switch:0') +def shelly_powermeter(message, topicGroups: tuple[str]) -> list[dict]: + sensor = topicGroups[0].replace('-', '_') + msg = json.loads(message['payload']) + return [ + { 'name': 'powermeter_w', 'labels': [{'labelName': 'sensor', 'labelValue': sensor}], 'value': msg['apower'] }, + { 'name': 'powermeter_voltage_v', 'labels': [{'labelName': 'sensor', 'labelValue': sensor}], 'value': msg['voltage'] }, + { 'name': 'powermeter_current_a', 'labels': [{'labelName': 'sensor', 'labelValue': sensor}], 'value': msg['current'] }, + { 'name': 'powermeter_apparent_power_va', 'labels': [{'labelName': 'sensor', 'labelValue': sensor}], 'value': msg['apower'] }, + { 'name': 'powermeter_temp_f', 'labels': [{'labelName': 'sensor', 'labelValue': sensor}], 'value': f_from_c(msg['temperature']['tC']) }, + ] # yapf: disable