diff --git a/src/pv_controller/FromDevices.py b/src/pv_controller/FromDevices.py index be8fc83..6e6c389 100644 --- a/src/pv_controller/FromDevices.py +++ b/src/pv_controller/FromDevices.py @@ -53,7 +53,7 @@ class FromDevices(AbstractMqttPublisher): logger.error(f"Caught exception: {str(e)}") 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) logger.debug(f"mqtt message sent: {device.publish_topic} -> {payloadStr}") diff --git a/src/pv_controller/config.py b/src/pv_controller/config.py index ff9d0da..4308a8d 100644 --- a/src/pv_controller/config.py +++ b/src/pv_controller/config.py @@ -24,6 +24,7 @@ class OutputConfig(BaseModel): enabled: bool = Field(default=True) scan_rate: Optional[int] = Field(default=60) publish_topic: str + raw_output: Optional[bool] = Field(default=False) slave_id: int registers: List[RegisterConfig]