Mercurial > code > home > repos > mqtt_metrics
diff convert.py @ 5:8390d5d0d512
one mqtt message can convert to multiple measurements
author | drewp@bigasterisk.com |
---|---|
date | Sat, 10 Aug 2024 23:02:51 -0700 |
parents | cd1b8d7bda78 |
children | bc2a93b306e9 |
line wrap: on
line diff
--- a/convert.py Sat Aug 10 21:16:19 2024 -0700 +++ b/convert.py Sat Aug 10 23:02:51 2024 -0700 @@ -4,6 +4,10 @@ converters = [] +def f_from_c(c): + return (c * 9 / 5) + 32 + + def topic(topic_pattern: str): def decorator(func): @@ -15,8 +19,8 @@ @topic(r'([^-]+)-air-quality/sensor/particulate_matter__10_0__m_concentration/state') -def pm(message, topicGroups: tuple[str]): - return { +def pm(message, topicGroups: tuple[str]) -> list[dict]: + return [{ 'name': 'air_quality_pm', 'labels': [{ 'labelName': 'location', @@ -26,16 +30,16 @@ 'labelValue': '10', }], 'value': float(message['payload']), - } + }] @topic(r'([^-]+)-air-quality/sensor/air_temperature_c/state') -def air_temp(message, topicGroups: tuple[str]): - return { +def air_temp(message, topicGroups: tuple[str]) -> list[dict]: + return [{ 'name': 'air_temperature_f', 'labels': [{ 'labelName': 'location', 'labelValue': topicGroups[0], }], - 'value': (float(message['payload']) * 9 / 5) + 32, - } + 'value': f_from_c(float(message['payload'])), + }]