From ef7b483b8ebcc62c52b6494de5ddb0fe775989ac Mon Sep 17 00:00:00 2001 From: LKuemmel Date: Mon, 14 Sep 2026 16:03:13 +0200 Subject: [PATCH] Aktualisiere die Verarbeitung empfangener MQTT-Daten im Verbraucher --- packages/modules/consumers/generic/mqtt/consumer.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/packages/modules/consumers/generic/mqtt/consumer.py b/packages/modules/consumers/generic/mqtt/consumer.py index 215d273bef..4eb66275f4 100644 --- a/packages/modules/consumers/generic/mqtt/consumer.py +++ b/packages/modules/consumers/generic/mqtt/consumer.py @@ -34,12 +34,12 @@ def on_message(client, userdata, message): try: return ConsumerState( power=received_topics[f"{topic_prefix}power"], - imported=received_topics[f"{topic_prefix}imported"], - exported=received_topics[f"{topic_prefix}exported"], + imported=parse_received_topics("imported"), + exported=parse_received_topics("exported"), powers=parse_received_topics("powers"), voltages=parse_received_topics("voltages"), - currents=received_topics[f"{topic_prefix}currents"], - temperatures=received_topics[f"{topic_prefix}temperatures"], + currents=parse_received_topics("currents"), + temperatures=parse_received_topics("temperatures"), ) except KeyError: raise KeyError("Es wurden nicht alle notwendigen Daten empfangen.")