4 Commits
0.0.1 ... 0.0.5

Author SHA1 Message Date
f8f9449c99 another fix 2023-05-23 13:26:48 +02:00
ab35b815fb fix 2023-05-23 13:19:49 +02:00
ec3fb5c72c fix 2023-05-23 13:17:12 +02:00
9da6eab743 fix name 2023-05-23 13:13:02 +02:00
2 changed files with 7 additions and 7 deletions

View File

@ -28,7 +28,7 @@ dockerize:
- tags
variables:
GIT_STRATEGY: none
CONTAINER_NAME: level-preprocessor
CONTAINER_NAME: cem-preprocessor
script:
- docker stop $CONTAINER_NAME || echo "container not running, never mind"
- docker rm $CONTAINER_NAME || echo "container not existing, never mind"

View File

@ -63,7 +63,7 @@ class DbOp(object):
'unit': res[2]
}
logger.debug(f"{variable=}")
return application
return variable
except Exception as e:
logger.error(f"Error getting variable: {e}")
raise VariableNotFoundException(appId, converterId, deviceId, variableId)
@ -100,14 +100,14 @@ def splitTopic(topic):
except ValueError:
raise InvalidTopicException(topic)
r = rest.split('/')
if (len(r) == 1:
if (len(r) == 1):
deviceId = 'mains',
variableId = r[0]
elif (len(r) == 2:
(deviceId, variableid) = r
elif (len(r) == 2):
(deviceId, variableId) = r
else:
raise InvalidTopicException(topic)
return (appId, converterId, deviceId, variableid)
return (appId, converterId, deviceId, variableId)
def mqttOnConnectCallback(client, userdata, flags, rc):
logger.info("mqtt connected")
@ -124,7 +124,7 @@ def mqttOnMessageCallback(client, userdata, message):
(appId, converterId, deviceId, variableId) = splitTopic(topic)
dbh = DbOp(config)
variable = dbh.getVariable(appId, converterId, deviceId, variableid)
variable = dbh.getVariable(appId, converterId, deviceId, variableId)
measurement = {
"application": variable["application"],
"variable": variable["variable"],