From 008713167de17caf9c44b0c9ddaadc86e862b6d4 Mon Sep 17 00:00:00 2001 From: Wolfgang Hottgenroth Date: Fri, 4 Feb 2022 23:29:57 +0100 Subject: [PATCH] uptime in status message --- opcua2mqtt/MqttPublish.py | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/opcua2mqtt/MqttPublish.py b/opcua2mqtt/MqttPublish.py index c03d976..3714901 100644 --- a/opcua2mqtt/MqttPublish.py +++ b/opcua2mqtt/MqttPublish.py @@ -3,7 +3,7 @@ from loguru import logger from MqttBase import AbstractMqttPublisher from queue import Empty import json - +import datetime LOOP_SLICE = 0.1 # seconds @@ -17,6 +17,7 @@ class MqttPublish(AbstractMqttPublisher): def localLoop(self): cnt = 0 + startTime = datetime.datetime.now() while not self.killBill: try: dataObject = self.queue.get(timeout=LOOP_SLICE) @@ -29,7 +30,9 @@ class MqttPublish(AbstractMqttPublisher): cnt += 1 logger.debug("mqtt message sent: {} -> {}".format(topic, payload)) if cnt % 100 == 1: - payload = { "count": cnt } + currentTime = datetime.datetime.now() + uptime = int((currentTime - startTime).total_seconds()) + payload = { "count": cnt, "uptime": uptime } self.client.publish(self.statusTopic, json.dumps(payload), retain=True) except Empty: if self.killBill: