Compare commits
4 Commits
Author | SHA1 | Date | |
---|---|---|---|
ac4a032b62
|
|||
69e8a507aa
|
|||
dea278bf03
|
|||
cc7af48f93
|
@ -30,7 +30,7 @@ deploy:
|
|||||||
- tags
|
- tags
|
||||||
variables:
|
variables:
|
||||||
GIT_STRATEGY: none
|
GIT_STRATEGY: none
|
||||||
CONTAINER_NAME: preprocessor
|
CONTAINER_NAME: badesee-preprocessor
|
||||||
script:
|
script:
|
||||||
- docker stop $CONTAINER_NAME || echo "container not running, never mind"
|
- docker stop $CONTAINER_NAME || echo "container not running, never mind"
|
||||||
- docker rm $CONTAINER_NAME || echo "container not existing, never mind"
|
- docker rm $CONTAINER_NAME || echo "container not existing, never mind"
|
||||||
@ -49,6 +49,7 @@ deploy:
|
|||||||
-e "PGPASSWORD=$PGPASSWORD"
|
-e "PGPASSWORD=$PGPASSWORD"
|
||||||
-e "PGDATABASE=$PGDATABASE"
|
-e "PGDATABASE=$PGDATABASE"
|
||||||
$IMAGE_NAME:$CI_COMMIT_TAG
|
$IMAGE_NAME:$CI_COMMIT_TAG
|
||||||
|
- docker network connect external-network $CONTAINER_NAME
|
||||||
environment:
|
environment:
|
||||||
name: production
|
name: production
|
||||||
|
|
||||||
|
@ -33,10 +33,6 @@ insert into sensor_t (address, label, index, device)
|
|||||||
(10664523975231507496, '3,0m ', 2, 1),
|
(10664523975231507496, '3,0m ', 2, 1),
|
||||||
(15276209993662477608, '4,0m ', 3, 1);
|
(15276209993662477608, '4,0m ', 3, 1);
|
||||||
|
|
||||||
select d.label as device_label,
|
create user preprocessor password 'geheim';
|
||||||
s.label as label,
|
grant select on device_t, sensor_t to preprocessor;
|
||||||
s.address as address,
|
grant insert on measurement_t to preprocessor;
|
||||||
s.index as index
|
|
||||||
from device_t d, sensor_t s
|
|
||||||
where d.id = s.device;
|
|
||||||
|
|
||||||
|
@ -70,8 +70,8 @@ class DbOp(object):
|
|||||||
with conn:
|
with conn:
|
||||||
with conn.cursor() as cur:
|
with conn.cursor() as cur:
|
||||||
for entry in measurement['measurements']:
|
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)",
|
cur.execute("insert into measurement_t (time, device_name, sensor_name, temperature) values (now(), %(dname)s, %(sname)s, %(tempc)s)",
|
||||||
{ 'time': measurement['time'], 'dname': measurement['label'], 'sname': entry['label'], 'tempc': entry['value'] })
|
{ 'dname': measurement['label'], 'sname': entry['label'], 'tempc': entry['value'] })
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
logger.error(f"Error storing measurement: {e}")
|
logger.error(f"Error storing measurement: {e}")
|
||||||
finally:
|
finally:
|
||||||
|
Reference in New Issue
Block a user