mirror/thingsboard-gateway
1
0
Fork 0
mirror of https://github.com/thingsboard/thingsboard-gateway synced 2025-10-26 22:31:42 +08:00
Code Issues Releases Wiki Activity

Updated example of custom mqtt converter to match new configuration structure

Browse Source
This commit is contained in:
samson0v 2024-06-14 10:00:08 +03:00
parent 17dbc9c75a
commit b795476799
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
thingsboard_gateway/extensions/mqtt/custom_mqtt_uplink_converter.py
View File

@ -35,10 +35,11 @@ class CustomMqttUplinkConverter(MqttUplinkConverter):
dict_result["telemetry"] = [] # template for telemetry array
bytes_to_read = body.replace("0x", "") # Replacing the 0x (if '0x' in body), needs for converting to bytearray
converted_bytes = bytearray.fromhex(bytes_to_read) # Converting incoming data to bytearray
if self.__config.get("extension-config") is not None:
for telemetry_key in self.__config["extension-config"]: # Processing every telemetry key in config for extension
extension_config_key = "extensionConfig" if self.__config.get("extensionConfig") is not None else "extension-config"
if self.__config.get(extension_config_key) is not None:
for telemetry_key in self.__config[extension_config_key]: # Processing every telemetry key in config for extension
value = 0
for _ in range(self.__config["extension-config"][telemetry_key]): # reading every value with value length from config
for _ in range(self.__config[extension_config_key][telemetry_key]): # reading every value with value length from config
value = value * 256 + converted_bytes.pop(0) # process and remove byte from processing
telemetry_to_send = {telemetry_key.replace("Bytes", ""): value} # creating telemetry data for sending into Thingsboard
dict_result["telemetry"].append(telemetry_to_send) # adding data to telemetry array