From 0c5086de0ab6c8d2f9df455e3ab79c3125389a39 Mon Sep 17 00:00:00 2001 From: Xunyu Wang <3400973+xunyuw@users.noreply.github.com> Date: Sun, 17 Nov 2024 17:35:00 +0800 Subject: [PATCH] Update tb_device_mqtt.py Fix orjson dump auto covert uint16 to int32 data error --- tb_device_mqtt.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/tb_device_mqtt.py b/tb_device_mqtt.py index d29bbaf..38f53ee 100644 --- a/tb_device_mqtt.py +++ b/tb_device_mqtt.py @@ -33,7 +33,7 @@ from paho.mqtt.client import MQTT_ERR_QUEUE_SIZE from orjson import dumps, loads, JSONDecodeError - +import simplejson from sdk_utils import verify_checksum FW_TITLE_ATTR = "fw_title" @@ -901,7 +901,7 @@ def __send_split_message(self, results, part, kwargs, timeout, device, msg_rate_ return rate_limited if msg_rate_limit.has_limit() or dp_rate_limit.has_limit(): msg_rate_limit.increase_rate_limit_counter() - kwargs["payload"] = dumps(part['message']) + kwargs["payload"] = simplejson.dumps(part['message']) self._wait_until_current_queued_messages_processed() if not self.stopped: if device is not None: @@ -1268,7 +1268,7 @@ def __on_connect(self, client, _, __, rc): # Callback for connect if rc == 0: log.info("[Provisioning client] Connected to ThingsBoard ") client.subscribe(self.PROVISION_RESPONSE_TOPIC) # Subscribe to provisioning response topic - provision_request = dumps(self.__provision_request) + provision_request = simplejson.dumps(self.__provision_request) log.info("[Provisioning client] Sending provisioning request %s" % provision_request) client.publish(self.PROVISION_REQUEST_TOPIC, provision_request) # Publishing provisioning request topic else: