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

time handling

Browse Source
This commit is contained in:
Wolfgang Hottgenroth 2023-01-30 17:40:03 +01:00
parent cc7af48f93
commit dea278bf03
Signed by: wn
GPG Key ID: 836E9E1192A6B132
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
.gitlab-ci.yml
View File

@ -49,7 +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 bridge $CONTAINER_NAME - docker network connect external-network $CONTAINER_NAME
environment: environment:
name: production name: production

4
src/preprocess.py
View File

@ -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: