3 Commits
0.0.4 ... 0.0.6

Author SHA1 Message Date
ac4a032b62 rename container 2023-02-17 11:57:29 +01:00
69e8a507aa schema changes 2023-01-30 21:39:34 +01:00
dea278bf03 time handling 2023-01-30 17:40:03 +01:00
3 changed files with 7 additions and 11 deletions

View File

@ -30,7 +30,7 @@ deploy:
- tags
variables:
GIT_STRATEGY: none
CONTAINER_NAME: preprocessor
CONTAINER_NAME: badesee-preprocessor
script:
- docker stop $CONTAINER_NAME || echo "container not running, never mind"
- docker rm $CONTAINER_NAME || echo "container not existing, never mind"
@ -49,7 +49,7 @@ deploy:
-e "PGPASSWORD=$PGPASSWORD"
-e "PGDATABASE=$PGDATABASE"
$IMAGE_NAME:$CI_COMMIT_TAG
- docker network connect bridge $CONTAINER_NAME
- docker network connect external-network $CONTAINER_NAME
environment:
name: production

View File

@ -33,10 +33,6 @@ insert into sensor_t (address, label, index, device)
(10664523975231507496, '3,0m ', 2, 1),
(15276209993662477608, '4,0m ', 3, 1);
select d.label as device_label,
s.label as label,
s.address as address,
s.index as index
from device_t d, sensor_t s
where d.id = s.device;
create user preprocessor password 'geheim';
grant select on device_t, sensor_t to preprocessor;
grant insert on measurement_t to preprocessor;

View File

@ -70,8 +70,8 @@ class DbOp(object):
with conn:
with conn.cursor() as cur:
for entry in measurement['measurements']:
cur.execute("insert into measurement_t (time, device_name, sensor_name, temperature) values (%(time)s, %(dname)s, %(sname)s, %(tempc)s)",
{ 'time': measurement['time'], 'dname': measurement['label'], 'sname': entry['label'], 'tempc': entry['value'] })
cur.execute("insert into measurement_t (time, device_name, sensor_name, temperature) values (now(), %(dname)s, %(sname)s, %(tempc)s)",
{ 'dname': measurement['label'], 'sname': entry['label'], 'tempc': entry['value'] })
except Exception as e:
logger.error(f"Error storing measurement: {e}")
finally: