This commit is contained in:
@@ -53,7 +53,7 @@ class FromDevices(AbstractMqttPublisher):
|
|||||||
logger.error(f"Caught exception: {str(e)}")
|
logger.error(f"Caught exception: {str(e)}")
|
||||||
|
|
||||||
payload['cnt'] = cnt
|
payload['cnt'] = cnt
|
||||||
payloadStr = json.dumps(payload)
|
payloadStr = json.dumps(payload) if not device.raw_output else str(payload)
|
||||||
self.client.publish(device.publish_topic, payloadStr)
|
self.client.publish(device.publish_topic, payloadStr)
|
||||||
logger.debug(f"mqtt message sent: {device.publish_topic} -> {payloadStr}")
|
logger.debug(f"mqtt message sent: {device.publish_topic} -> {payloadStr}")
|
||||||
|
|
||||||
|
|||||||
@@ -24,6 +24,7 @@ class OutputConfig(BaseModel):
|
|||||||
enabled: bool = Field(default=True)
|
enabled: bool = Field(default=True)
|
||||||
scan_rate: Optional[int] = Field(default=60)
|
scan_rate: Optional[int] = Field(default=60)
|
||||||
publish_topic: str
|
publish_topic: str
|
||||||
|
raw_output: Optional[bool] = Field(default=False)
|
||||||
slave_id: int
|
slave_id: int
|
||||||
registers: List[RegisterConfig]
|
registers: List[RegisterConfig]
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user