feature/backend #4
| @ -116,8 +116,12 @@ def on_message(mqttc, obj, msg): | ||||
|     #print("\nMessage: " + msg.topic + " " + str(msg.qos)) | ||||
|     parsedJSON = json.loads(msg.payload) | ||||
|     #print(json.dumps(parsedJSON, indent=4)) | ||||
|     uplink_message = parsedJSON["uplink_message"]; | ||||
|     update_metrics(uplink_message["decoded_payload"], uplink_message["rx_metadata"]) | ||||
|  | ||||
|     try:  | ||||
|         uplink_message = parsedJSON["uplink_message"]; | ||||
|         update_metrics(uplink_message["decoded_payload"], uplink_message["rx_metadata"]) | ||||
|     except: | ||||
|         print("Unable to parse uplink") | ||||
|  | ||||
| def on_subscribe(mqttc, obj, mid, granted_qos): | ||||
|     print("\nSubscribed to MQTT: " + str(mid) + " " + str(granted_qos)) | ||||
|  | ||||
		Reference in New Issue
	
	Block a user