From 122fce519cf8f0d52b33c984aeaf6329eb2dd317 Mon Sep 17 00:00:00 2001 From: Wolfgang Hottgenroth Date: Wed, 17 Jul 2019 16:01:28 +0100 Subject: [PATCH] coil stuff --- src/RegisterDatapoint.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/RegisterDatapoint.py b/src/RegisterDatapoint.py index c40d51f..7c7b52d 100644 --- a/src/RegisterDatapoint.py +++ b/src/RegisterDatapoint.py @@ -135,7 +135,7 @@ class CoilDatapoint(AbstractModbusDatapoint): self.publishTopic, self.subscribeTopic, self.feedbackTopic)) def onMessage(self, value): - self.writeRequestValue = value + self.writeRequestValue = value.decode() def process(self, client, pubQueue): logger = logging.getLogger('CoilDatapoint') @@ -161,12 +161,12 @@ class CoilDatapoint(AbstractModbusDatapoint): # perform read operation logger.debug("Coil, perform read operation") self.processCount += 1 - result = client.read_coil(address=self.address, - unit=self.unit) + result = client.read_coils(address=self.address, + unit=self.unit) if type(result) in [ExceptionResponse, ModbusIOException]: self.errorCount += 1 raise DatapointException(result) - logger.debug("{0}: {1!s}".format(self.label, result.registers)) + logger.debug("{0}: {1!s}".format(self.label, result.getBit(0))) value = result.getBit(0) if self.publishTopic: pubQueue.put(MqttProcessor.PublishItem(self.publishTopic, str(value)))