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-05-23 13:19:49 +02:00
parent ec3fb5c72c
commit ab35b815fb
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/preprocess.py
View File

@ -104,10 +104,10 @@ def splitTopic(topic):
deviceId = 'mains', deviceId = 'mains',
variableId = r[0] variableId = r[0]
elif (len(r) == 2): elif (len(r) == 2):
(deviceId, variableid) = r (deviceId, variableId) = r
else: else:
raise InvalidTopicException(topic) raise InvalidTopicException(topic)
return (appId, converterId, deviceId, variableid) return (appId, converterId, deviceId, variableId)
def mqttOnConnectCallback(client, userdata, flags, rc): def mqttOnConnectCallback(client, userdata, flags, rc):
logger.info("mqtt connected") logger.info("mqtt connected")
@ -124,7 +124,7 @@ def mqttOnMessageCallback(client, userdata, message):
(appId, converterId, deviceId, variableId) = splitTopic(topic) (appId, converterId, deviceId, variableId) = splitTopic(topic)
dbh = DbOp(config) dbh = DbOp(config)
variable = dbh.getVariable(appId, converterId, deviceId, variableid) variable = dbh.getVariable(appId, converterId, deviceId, variableId)
measurement = { measurement = {
"application": variable["application"], "application": variable["application"],
"variable": variable["variable"], "variable": variable["variable"],