Fix MQTT JSON decoding
This commit is contained in:
@@ -74,8 +74,8 @@ class Mqtt(object):
|
|||||||
def _on_message_handler(self, client, userdata, message):
|
def _on_message_handler(self, client, userdata, message):
|
||||||
# Parse payload JSON
|
# Parse payload JSON
|
||||||
try:
|
try:
|
||||||
j = _util.parse_json(message.payload)
|
j = _util.parse_json(message.payload.decode("utf-8"))
|
||||||
except _exception.FBchatFacebookError:
|
except (_exception.FBchatFacebookError, UnicodeDecodeError):
|
||||||
log.exception("Failed parsing MQTT data on %s as JSON", message.topic)
|
log.exception("Failed parsing MQTT data on %s as JSON", message.topic)
|
||||||
return
|
return
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user