Compare commits
3 Commits
Author | SHA1 | Date | |
---|---|---|---|
ac4a032b62
|
|||
69e8a507aa
|
|||
dea278bf03
|
@ -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
|
||||
|
||||
|
@ -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;
|
||||
|
@ -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:
|
||||
|
Reference in New Issue
Block a user