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

Compare commits

base: neben:0.0.2
Branches Tags
neben:main
neben:0.0.4 neben:0.0.3 neben:0.0.2 neben:0.0.1
...
compare: neben:0.0.4
Branches Tags
neben:main
neben:0.0.4 neben:0.0.3 neben:0.0.2 neben:0.0.1

2 Commits
0.0.2 ... 0.0.4

Author SHA1 Message Date
Wolfgang Hottgenroth
5075af27d1 fix decoding 2023-06-02 20:51:05 +02:00
Wolfgang Hottgenroth
5427e3f277 fix typo 2023-06-02 20:39:09 +02:00
1 changed files with 5 additions and 7 deletions
Expand all files Collapse all files

12
src/preprocess.py
View File

@ -64,7 +64,7 @@ class DbOp(object):
with conn.cursor() as cur: with conn.cursor() as cur:
cur.execute(""" cur.execute("""
insert into measurement_t (time, application_name, moisture, temperature, conductivity, status, battery) insert into measurement_t (time, application_name, moisture, temperature, conductivity, status, battery)
values (now(), %(application_name)s, %(moisture)s, %(temperature)s, %(conductivity), %(status)s, %(battery)s) values (now(), %(application_name)s, %(moisture)s, %(temperature)s, %(conductivity)s, %(status)s, %(battery)s)
""", """,
{ {
'application_name': measurement['application_name'], 'application_name': measurement['application_name'],
@ -107,15 +107,13 @@ def mqttOnMessageCallback(client, userdata, message):
match application['sensor_type']: match application['sensor_type']:
case 'LSE01': case 'LSE01':
battery = struct.unpack('>H', frame[0:2])[0] battery = struct.unpack('>H', frame[0:2])[0]
moisture = struct.unpack('>H', frame[2:4])[0] moisture = struct.unpack('>H', frame[4:6])[0]
temperature = struct.unpack('>H', frame[4:6])[0] temperature = struct.unpack('>H', frame[6:8])[0]
conductivity = struct.unpack('>H', frame[6:8])[0] conductivity = struct.unpack('>H', frame[8:10])[0]
status = struct.unpack('?', frame[8:9])[0] status = struct.unpack('?', frame[10:11])[0]
logger.debug(f"{frame=}, {battery=}, {moisture=}, {temperature=}, {conductivity=}, {status=}") logger.debug(f"{frame=}, {battery=}, {moisture=}, {temperature=}, {conductivity=}, {status=}")
statusText = 'Ok' statusText = 'Ok'
if not status:
statusText = 'No sensor'
measurement = { measurement = {
'application_name': application['label'], 'application_name': application['label'],