fix logging
This commit is contained in:
@ -34,7 +34,7 @@ class MeterPublish(AbstractMqttPublisher):
|
|||||||
payload['timestamp'] = datetime.datetime.isoformat(datetime.datetime.utcnow())
|
payload['timestamp'] = datetime.datetime.isoformat(datetime.datetime.utcnow())
|
||||||
for reg in self.registers:
|
for reg in self.registers:
|
||||||
v = self.modbusHandler.readInputRegister(reg['addr'])
|
v = self.modbusHandler.readInputRegister(reg['addr'])
|
||||||
logger.info(f"{reg['name']}: {v} {reg['unit']}")
|
logger.debug(f"{reg['name']}: {v} {reg['unit']}")
|
||||||
payload[reg['attr']] = float(f"{v:0.2f}")
|
payload[reg['attr']] = float(f"{v:0.2f}")
|
||||||
payload['status'] = "Ok"
|
payload['status'] = "Ok"
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
@ -43,6 +43,6 @@ class MeterPublish(AbstractMqttPublisher):
|
|||||||
payload['cnt'] = cnt
|
payload['cnt'] = cnt
|
||||||
payloadStr = json.dumps(payload)
|
payloadStr = json.dumps(payload)
|
||||||
self.client.publish(topic, payloadStr)
|
self.client.publish(topic, payloadStr)
|
||||||
logger.warning(f"mqtt message sent: {topic} -> {payloadStr}")
|
logger.info(f"mqtt message sent: {topic} -> {payloadStr}")
|
||||||
|
|
||||||
self.killEvent.wait(timeout=float(self.config["meterPublishPeriod"]))
|
self.killEvent.wait(timeout=float(self.config["meterPublishPeriod"]))
|
||||||
|
Reference in New Issue
Block a user