Fix mqtt message so the json isn't double escaped

This commit is contained in:
Pat Riehecky 2019-05-16 13:27:24 -05:00
parent 8a81bc8622
commit dc7af13b6c

View file

@ -165,7 +165,7 @@ def on_mqtt_message(client, userdata, message):
logging.debug('Message received topic:%s payload:%s', message.topic, message.payload.decode("utf-8")) logging.debug('Message received topic:%s payload:%s', message.topic, message.payload.decode("utf-8"))
# Or you can customize this to fit your needs # Or you can customize this to fit your needs
signal = {message.topic: message.payload.decode("utf-8")} signal = {message.topic: json.loads(message.payload.decode("utf-8"))}
userdata['emit'].message(json.dumps((signal))) userdata['emit'].message(json.dumps((signal)))
logging.debug('Sending signal: %s', json.dumps(signal)) logging.debug('Sending signal: %s', json.dumps(signal))