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

fix

Browse Source
This commit is contained in:
Wolfgang Hottgenroth 2023-11-09 18:04:05 +01:00
parent 0eb133cede
commit 58f17be962
Signed by: wn
GPG Key ID: 836E9E1192A6B132
4 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Dockerfile
View File

@ -3,7 +3,7 @@ FROM python:3.10-bullseye
ENV MQTT_LOGIN "-" ENV MQTT_LOGIN "-"
ENV MQTT_PASSWORD "-" ENV MQTT_PASSWORD "-"
ENV MQTT_BROKER "-" ENV MQTT_BROKER "-"
ENV MQTT_PORT "8883" ENV MQTT_PORT "1883"
ENV MQTT_CA "" ENV MQTT_CA ""
ENV PGHOST "" ENV PGHOST ""

1
deployment/install.sh
View File

@ -8,5 +8,4 @@ NAMESPACE=$(cat namespace)
kubectl -f install.yml -n $NAMESPACE apply kubectl -f install.yml -n $NAMESPACE apply
kubectl apply -f - -n $NAMESPACE

2
deployment/install.yml
View File

@ -26,7 +26,7 @@ spec:
spec: spec:
containers: containers:
- name: cemmetering - name: cemmetering
image: wollud1969/cemmetering-preprocessor:1.0.0 image: wollud1969/cemmetering-preprocessor:1.0.1
envFrom: envFrom:
- configMapRef: - configMapRef:
name: cemmetering name: cemmetering

4
src/preprocess.py
View File

@ -29,7 +29,7 @@ class JustIgnoreMessage (Exception):
self.message = message self.message = message
class DbOp(object): class DbOp(object):
def __init__(self, config): def __init__(self):
self.conn = None self.conn = None
def __getConn(self): def __getConn(self):
@ -125,7 +125,7 @@ def mqttOnMessageCallback(client, userdata, message):
(appId, converterId, deviceId, variableId) = splitTopic(topic) (appId, converterId, deviceId, variableId) = splitTopic(topic)
dbh = DbOp(config) dbh = DbOp()
variable = dbh.getVariable(appId, converterId, deviceId, variableId) variable = dbh.getVariable(appId, converterId, deviceId, variableId)
measurement = { measurement = {
"vid": variable["vid"], "vid": variable["vid"],