neben/levelmetering-preprocessor
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add radar support

Browse Source
This commit is contained in:
Wolfgang Hottgenroth 2023-02-23 22:00:42 +01:00
parent ce9e047d22
commit 63df1a25d1
Signed by: wn
GPG Key ID: 836E9E1192A6B132
1 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/preprocess.py
View File

@ -19,7 +19,11 @@ class SensorTypeNotFoundException (Exception):
def __init__(self, sensorType):
self.sensorType = sensorType
class JustIgnoreMessage (Exception): pass
class JustIgnoreMessage (Exception):
def __init__(self, application, device, message):
self.application = application
self.device = device
self.message = message
class DbOp(object):
def __init__(self, config):
@ -122,10 +126,10 @@ def mqttOnMessageCallback(client, userdata, message):
}
case 'LMDS200':
if f_port != 2:
raise JustIgnoreMessage()
raise JustIgnoreMessage(application['label'], device_id, f"ignore message for f_port {f_port}")
battery = struct.unpack('>H', frame[0:2])[0]
distance1 = struct.unpack('>H', frame[2:4])[0]
distance2 = struct.unpack('>H', frame[4:6])[0]
distance1 = struct.unpack('>H', frame[2:4])[0] * 10
distance2 = struct.unpack('>H', frame[4:6])[0] * 10
logger.debug(f"{frame=}, {battery=}, {distance1=}, {distance2=}")
statusText = 'Ok'
@ -146,8 +150,8 @@ def mqttOnMessageCallback(client, userdata, message):
logger.debug(f"{measurement=}")
dbh.storeMeasurement(measurement)
except JustIgnoreMessage:
pass
except JustIgnoreMessage as e:
logger.info(f"JustIgnoreMessage: {e.application}, {e.device}, {e.message}")
except SensorTypeNotFoundException as e:
logger.error(f"application has unknown sensor type {e.sensorType}")
except ApplicationNotFoundException as e: