diff --git a/packages/modules/consumers/generic/mqtt/consumer.py b/packages/modules/consumers/generic/mqtt/consumer.py index cc6b8941c6..215d273bef 100644 --- a/packages/modules/consumers/generic/mqtt/consumer.py +++ b/packages/modules/consumers/generic/mqtt/consumer.py @@ -39,6 +39,7 @@ def on_message(client, userdata, message): powers=parse_received_topics("powers"), voltages=parse_received_topics("voltages"), currents=received_topics[f"{topic_prefix}currents"], + temperatures=received_topics[f"{topic_prefix}temperatures"], ) except KeyError: raise KeyError("Es wurden nicht alle notwendigen Daten empfangen.")