From 67bb990190ed6c8c3cc5b394db669bf138bf61df Mon Sep 17 00:00:00 2001 From: Gleb Tcivie Date: Thu, 27 Jun 2024 23:54:10 +0300 Subject: [PATCH] Fixed issue when exporter tried to parse messages from the stat folder in MQTT --- main.py | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/main.py b/main.py index 8fb4b92..d4be407 100644 --- a/main.py +++ b/main.py @@ -21,6 +21,12 @@ def handle_connect(client, userdata, flags, reason_code, properties): def handle_message(client, userdata, message): current_timestamp = datetime.now().strftime('%Y-%m-%d %H:%M:%S') print(f"Received message on topic '{message.topic}' at {current_timestamp}") + + # Filter out messages from the 'stat' topic + if '/stat/' in message.topic: + print(f"Filtered out message from topic containing '/stat/': {message.topic}") + return + envelope = ServiceEnvelope() envelope.ParseFromString(message.payload)