Compare commits
1 Commits
Author | SHA1 | Date | |
---|---|---|---|
ab35b815fb
|
@ -104,10 +104,10 @@ def splitTopic(topic):
|
||||
deviceId = 'mains',
|
||||
variableId = r[0]
|
||||
elif (len(r) == 2):
|
||||
(deviceId, variableid) = r
|
||||
(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"],
|
||||
|
Reference in New Issue
Block a user