wn/modbusmaster
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

coil stuff

Browse Source
This commit is contained in:
Wolfgang Hottgenroth 2019-07-17 16:01:28 +01:00
parent 4200aaf304
commit 122fce519c
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/RegisterDatapoint.py
View File

@ -135,7 +135,7 @@ class CoilDatapoint(AbstractModbusDatapoint):
self.publishTopic, self.subscribeTopic, self.feedbackTopic)) self.publishTopic, self.subscribeTopic, self.feedbackTopic))
def onMessage(self, value): def onMessage(self, value):
self.writeRequestValue = value self.writeRequestValue = value.decode()
def process(self, client, pubQueue): def process(self, client, pubQueue):
logger = logging.getLogger('CoilDatapoint') logger = logging.getLogger('CoilDatapoint')
@ -161,12 +161,12 @@ class CoilDatapoint(AbstractModbusDatapoint):
# perform read operation # perform read operation
logger.debug("Coil, perform read operation") logger.debug("Coil, perform read operation")
self.processCount += 1 self.processCount += 1
result = client.read_coil(address=self.address, result = client.read_coils(address=self.address,
unit=self.unit) unit=self.unit)
if type(result) in [ExceptionResponse, ModbusIOException]: if type(result) in [ExceptionResponse, ModbusIOException]:
self.errorCount += 1 self.errorCount += 1
raise DatapointException(result) 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) value = result.getBit(0)
if self.publishTopic: if self.publishTopic:
pubQueue.put(MqttProcessor.PublishItem(self.publishTopic, str(value))) pubQueue.put(MqttProcessor.PublishItem(self.publishTopic, str(value)))