3 Commits
0.0.2 ... 0.0.5

Author SHA1 Message Date
dea278bf03 time handling 2023-01-30 17:40:03 +01:00
cc7af48f93 network 2023-01-30 15:00:05 +01:00
d2a07a6924 fix in ci 2023-01-30 14:40:49 +01:00
3 changed files with 8 additions and 4 deletions

View File

@ -39,16 +39,17 @@ deploy:
-d -d
--name $CONTAINER_NAME --name $CONTAINER_NAME
--restart always --restart always
--link timescaledb-server --network internal-network
-e "APPLICATION_TENANT=$APPLICATION_TENANT" -e "APPLICATION_TENANT=$APPLICATION_TENANT"
-e "MQTT_LOGIN=$MQTT_LOGIN" -e "MQTT_LOGIN=$MQTT_LOGIN"
-e "MQTT_PASSWORD=$MQTT_PASSWORD" -e "MQTT_PASSWORD=$MQTT_PASSWORD"
-e "MQTT_BROKER=$MQTT_BROKER" -e "MQTT_BROKER=$MQTT_BROKER"
-e "PGHOST=timescaledb-server" -e "PGHOST=timescaledb"
-e "PGUSER=$PGUSER" -e "PGUSER=$PGUSER"
-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

View File

@ -1,3 +1,6 @@
create database monitoring;
create extension timescaledb;
CREATE TABLE device_t ( CREATE TABLE device_t (
id SERIAL NOT NULL PRIMARY KEY, id SERIAL NOT NULL PRIMARY KEY,
device_id VARCHAR(32) NOT NULL UNIQUE, device_id VARCHAR(32) NOT NULL UNIQUE,

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: