Skip to content

Commit 7f8772a

Browse files
committed
Fix for non str keys
1 parent 33e4701 commit 7f8772a

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

tb_device_mqtt.py

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,9 @@
1717
from inspect import signature
1818
from time import sleep
1919
from importlib import metadata
20+
21+
from orjson.orjson import OPT_NON_STR_KEYS
22+
2023
from utils import install_package
2124
from os import environ
2225

@@ -1134,7 +1137,7 @@ def __send_split_message(self, results, part, kwargs, timeout, device, msg_rate_
11341137
return rate_limited
11351138
if msg_rate_limit.has_limit() or dp_rate_limit.has_limit():
11361139
msg_rate_limit.increase_rate_limit_counter()
1137-
kwargs["payload"] = dumps(part['message'])
1140+
kwargs["payload"] = dumps(part['message'], option=OPT_NON_STR_KEYS)
11381141
if msg_rate_limit.has_limit() or dp_rate_limit.has_limit():
11391142
self._wait_until_current_queued_messages_processed()
11401143
if not self.stopped:
@@ -1501,7 +1504,7 @@ def __on_connect(self, client, _, __, rc): # Callback for connect
15011504
if rc == 0:
15021505
log.info("[Provisioning client] Connected to ThingsBoard ")
15031506
client.subscribe(self.PROVISION_RESPONSE_TOPIC) # Subscribe to provisioning response topic
1504-
provision_request = dumps(self.__provision_request)
1507+
provision_request = dumps(self.__provision_request, option=OPT_NON_STR_KEYS)
15051508
log.info("[Provisioning client] Sending provisioning request %s" % provision_request)
15061509
client.publish(self.PROVISION_REQUEST_TOPIC, provision_request) # Publishing provisioning request topic
15071510
else:

0 commit comments

Comments
 (0)