Changes for page ThingsBoard
Last modified by Dilisi S on 2025/04/23 19:23
Summary
-
Page properties (1 modified, 0 added, 0 removed)
-
Attachments (0 modified, 12 added, 6 removed)
- add-downlink-data-converter.png
- add-uplink-data-converter.png
- create-new-converter-menu.png
- data-converter-list-showing-uplink-dc.png
- data-converters-list-empty.png
- data-converters-list.png
- ThingsBoard-Data-Converters.png
- ThingsBoard-Device.png
- ThingsBoard-add-data-converter-downlink.png
- ThingsBoard-add-data-converter-uplink.png
- ThingsBoard-add-data-converter.png
- ThingsBoard-add-integration.png
- ThingsBoard-add-new-device.png
- ThingsBoard-new-data-converter.png
- add-integration-basic-settings.png
- add-integration-connection.png
- add-integration-downlink-data-converter.png
- add-integration-uplink-data-converter.png
Details
- Page properties
-
- Content
-
... ... @@ -6,135 +6,215 @@ 6 6 Draft Document 7 7 {{/warning}} 8 8 9 += Introduction = 9 9 11 +This document guides you on integrating Dragino -NB and -CB series devices with ThingsBoard. For this guide, we use ThingsBoard Cloud, which is one of the ThingsBoard versions that allows you to try it for free. 10 10 11 11 12 -= 1. Introduction=14 += Add New Device = 13 13 16 +In the left navigation, click **Entities** and then click **Devices**. 14 14 15 -This document guides you on integrating Dragino **-NB** and **-CB** series devices data with ThingsBoard. For this guide, we use ThingsBoard Cloud, which is one of the ThingsBoard versions that allows you to try it for free. 16 16 17 - The **NB series** devices end withthe suffix **-NB**, and the **CBseries** devices end with the suffix **-CB**. For example, **S31B-NB** is an **NBdevice**, and **S31-CB** is a **CB device**.19 +[[image:ThingsBoard-Device.png]] 18 18 19 19 22 +On the ‘**Devices**’ page, click on the ‘**+**’ button, and then click on the ‘**Add new device**’ from the dropdown menu. 20 20 21 21 25 +[[image:ThingsBoard-add-new-device.png||height="279" width="500"]] 22 22 23 -= 2. Data Converters = 24 24 25 25 26 - In **ThingsBoard**, **Data Converters** arecomponents used to transform incoming or outgoing data between different formats, typically to convert raw telemetry data from devices into a structured format that ThingsBoard can understand, or vice versa.29 += Data Converters = 27 27 28 28 29 -== 2.1Uplink ==32 +== Uplink == 30 30 34 +In the left navigation, click ‘Integrations center’, and then click ‘Data converters’. 31 31 32 -In the left navigation, click **Integrations center**, and then click **Data converters**. 33 33 37 +[[image:ThingsBoard-Data-Converters.png]] 34 34 35 35 36 - [[image:data-converters-list-empty.png]]40 +On the ‘Data converters’ page, click on the ‘+’ button, and then click on the ‘Create new converter’ from the dropdown menu. 37 37 38 38 39 - On the **Data converters** page, click onthe ‘**+**’ button,andthenclick on the**Create newconverter** from thedropdown menu.43 +[[image:ThingsBoard-new-data-converter.png||height="282" width="500"]] 40 40 41 41 46 +The ‘Add data converter’ window will appear. Name it ‘**UDP Uplink Converter NB/CB**’ and select the Type as ‘Uplink’. 42 42 43 - [[image:create-new-converter-menu.png||height="259"width="500"]]48 +Click on the ‘JavaScript’ button. Now copy and paste the following script to the ‘Decoder function’ section: 44 44 45 - 46 -The **Add data converter** window will appear. Name it ‘**MQTT Uplink Converter NB/CB**’ and select the Type as **Uplink**. 47 - 48 -Click on the **TBEL** button if not selected it by default. Delete the existing decoder function in the code editor. Now copy and paste the following decoder function written in **TBEL (ThingsBoard Expression Language)** in to the **code editor**. This decoder function is compatible for both NB and CB series devices. 49 - 50 50 {{code language="JavaScript"}} 51 -/** Decoder **/ 52 - 51 +//Version: 0.1 53 53 // decode payload to string 54 54 var payloadStr = decodeToString(payload); 55 -var data = JSON.parse(payloadStr); 56 56 57 -var deviceName = metadata.topic.split("/")[3]; 58 58 // decode payload to JSON 59 -var deviceType = 'sensor'; 56 +var objdata = {}; 57 +var obj1 = {}; 58 +var data = decodeToJson(payload); 59 +var deviceName = data.IMEI; 60 +delete data.IMEI; 61 +var modelname = "Dragino " + data.Model; 62 +//var mod = data.mod 63 +delete data.Model; 64 +//delete data.mod 65 +var timestamp = new Date().getTime(); 60 60 61 -// Result object with device attributes/telemetry data 67 +for (var key in data) { 68 + 69 + if (Number(key)) { 70 + obj1[key] = data[key]; 71 + obj1[key][obj1[key].length - 1] = Number(new Date( 72 + obj1[key][obj1[key].length - 1])); 73 + 74 + } 75 +//Alec submitted25/02/25 76 +//turn old key into new 77 + else if (key === "Reading") { 78 + objdata["reading"] = data[key]; 79 + } else if (key === "work mode") { 80 + objdata["work_mode"] = data[key]; 81 + } else if (key === "hum") { 82 + objdata["humidity"] = data[key]; 83 + }else if (key === "hum2") { 84 + objdata["humidity2"] = data[key]; 85 + } else if (key === "hum3") { 86 + objdata["humidity3"] = data[key]; 87 + } else if (key === "tem") { 88 + objdata["temperature"] = data[key]; 89 + } else if (key === "tem2") { 90 + objdata["temperature2"] = data[key]; 91 + } else if (key === "tem3") { 92 + objdata["temperature3"] = data[key]; 93 + } else if (key === "DS18B20_Temp") { 94 + objdata["temperature_pro"] = data[key]; 95 + } else if (key === "ds18b20_temperature") { 96 + objdata["temperature_pro"] = data[key]; 97 + } else if (key === "DS18B20_temperature_pro") { 98 + objdata["temperature_pro"] = data[key]; 99 + } else if (key === "tdc send flag") { 100 + objdata["tdc_send_flag"] = data[key]; 101 + } else if (key === "trigger mode") { 102 + objdata["trigger_mode"] = data[key]; 103 + } else if (key === "soil dielectric constant") { 104 + objdata["soil_dielectric_constant"] = data[key]; 105 + } else if (key === "door open num") { 106 + objdata["door_open_num"] = data[key]; 107 + } else if (key === "door duration") { 108 + objdata["door_duration"] = data[key]; 109 + } else if (key === "count time") { 110 + objdata["count_time"] = data[key]; 111 + } else if (key === "last open time2") { 112 + objdata["last_open_time2"] = data[key]; 113 + } else if (key === "last open time3") { 114 + objdata["last_open_time3"] = data[key]; 115 + } 116 +//Alec submitted25/02/25 117 + else { 118 + objdata[key] = data[key] 119 + } 120 +} 121 +var listdata = [{ 122 + "ts": timestamp, 123 + "values": objdata 124 +}] 125 +for (var key1 in obj1) { 126 + if (modelname == "Dragino RS485-NB") { 127 + listdata.push({ 128 + "ts": obj1[key1][obj1[key1].length - 1], 129 + "values": { 130 + "Payload": obj1[key1][0], 131 + } 132 + }) 133 + } else { 134 + listdata.push({ 135 + "ts": obj1[key1][obj1[key1].length - 1], 136 + "values": { 137 + "values": obj1[key1] 138 + }, 139 + }) 140 + } 141 +} 62 62 var result = { 143 + 63 63 deviceName: deviceName, 64 - deviceType: de viceType,145 + deviceType: modelname, 65 65 attributes: { 66 - integrationName: metadata['integrationName'], 147 + model: modelname, 148 + //customerName: "NB-CB", 149 + //groupName: "NB-CB", 150 + //integrationName: metadata['integrationName'] 151 + 67 67 }, 68 - telemetry: { 69 - temperature: data.temperature, 70 - humidity: data.humidity, 71 - } 72 -}; 153 + telemetry: listdata 154 +} 73 73 74 -/** Helper functions 'decodeToString' and 'decodeToJson' are already built-in **/ 156 +function decodeToString(payload) { 157 + return String.fromCharCode.apply(String, payload); 158 +} 75 75 76 -return result; 77 -{{/code}} 160 +function decodeToJson(payload) { 161 + // covert payload to string. 162 + var str = decodeToString(payload); 78 78 164 + // parse string to JSON 165 + var data = JSON.parse(str); 166 + return data; 167 +} 79 79 80 - Click onthe**Add** button.169 +return result; 81 81 171 +{{/code}} 82 82 173 +Click on the ‘Add’ button. 83 83 84 -[[image:add-uplink-data-converter.png||height="529" width="500"]] 85 85 176 +[[image:ThingsBoard-add-data-converter-uplink.png||width="500"]] 86 86 87 -You should see that the newly added **MQTT Uplink converter **NB/CB is listed on the **Data Converters** page. 88 88 179 +The uplink data converter is added to ThingsBoard and appears on the ‘Data Converters’ page 89 89 90 90 91 - [[image:create-new-converter-menu.png||width="500"]]182 +== Downlink == 92 92 93 - ==3.2Downlink==184 +On the ‘Data converters’ page, click on the ‘+’ button, and then click on the ‘Create new converter’ from the dropdown menu. 94 94 95 95 96 -On the **Data converters** page, click on the ‘**+**’ button, and then click on the **Create new converter** from the dropdown menu. 97 - 98 98 [[image:ThingsBoard-new-data-converter.png||height="282" width="500"]] 99 99 100 100 101 -The **Add data converter** MQTTDownlink Converter NB/CB**’ and select the Type as **Downlink**.190 +The ‘**Add data converter**’ window will appear. Name it ‘**UDP Downlink Converter NB/CB**’ and select the Type as ‘**Downlink**’. 102 102 103 -Click on the ** TBEL**if not selected it by default. Now copy and paste the followingencoderfunction writtenin **TBEL (ThingsBoard Expression Language)** into the **code editor**. This encoder functionisompatible for both NB and CB series devices.192 +Click on the ‘**JavaScript**’ button. Now copy and paste the following script to the ‘**Encoder function**’ section: 104 104 105 105 106 106 {{code language="JavaScript"}} 107 -// Encode downlink data from incoming Rule Engine message 196 +function hexToBase64(hexString) { 197 + // 将16进制字符串两个字符转换为一个字节 198 + var bytes = hexString.match(/.{2}/g); 199 + // 对每个字节进行解析,并转换为对应的字符 200 + var binaryString = bytes.map(function(byte) { 201 + return String.fromCharCode(parseInt(byte, 16)); 202 + }).join(''); 203 + 204 + // 使用btoa进行base64编码 205 + return btoa(binaryString); 206 +} 108 108 109 -// msg - JSON message payload downlink message json 110 -// msgType - type of message, for ex. 'ATTRIBUTES_UPDATED', 'POST_TELEMETRY_REQUEST', etc. 111 -// metadata - list of key-value pairs with additional data about the message 112 -// integrationMetadata - list of key-value pairs with additional data defined in Integration executing this converter 113 - 114 -/** Encoder **/ 115 - 116 -var data = {}; 117 - 118 -// Process data from incoming message and metadata 119 - 120 -data.tempFreq = msg.temperatureUploadFrequency; 121 -data.humFreq = msg.humidityUploadFrequency; 122 - 123 -data.devSerialNumber = metadata['ss_serialNumber']; 124 - 125 125 // Result object with encoded downlink payload 126 126 var result = { 127 - 128 128 // downlink data content type: JSON, TEXT or BINARY (base64 format) 129 - contentType: " JSON",211 + contentType: "BINARY", 130 130 131 131 // downlink data 132 - data: JSON.stringify(data),214 + data:hexToBase64(metadata.shared_value) 133 133 134 134 // Optional metadata object presented in key/value format 135 - metadata: { 136 - topic: metadata['deviceType']+'/'+metadata['deviceName']+'/upload' 137 - } 217 + //metadata: {} 138 138 139 139 }; 140 140 ... ... @@ -145,101 +145,80 @@ 145 145 Click on the **Add** button. 146 146 147 147 228 +[[image:ThingsBoard-add-data-converter-downlink.png||height="532" width="500"]] 148 148 149 -[[image:add-downlink-data-converter.png||height="529" width="500"]] 150 150 231 += Add Integration = 151 151 152 - Youshould seethat thenewly added**MQTT Downlink**ConverterNB/CBislistedon the**DataConverters** page.233 +In the left navigation, click ‘Integrations center’, and then click ‘Integrations’. 153 153 235 +On the ‘Integrations’ page, click on the “+” button. 154 154 155 155 156 -[[image:da ta-converters-list.png]]238 +[[image:ThingsBoard-add-integration.png]] 157 157 158 -= 3. Add Integration = 159 159 241 +The ‘Add integration’ window appears. 160 160 161 -In the leftnavigation, click **Integrationscenter**,andthenclick **Integrations**.243 +In the Add Integration window, configure the following settings: 162 162 163 -On the **Integrations** page, click on the '**+**' button. 164 - 165 -[[image:data-converter-list-page.png]] 166 - 167 - 168 -The **Add integration** window appears. 169 - 170 -In the **Add integration** window, configure the following settings: 171 - 172 - 173 173 **Basic settings:** 174 174 175 -* **Integration type**: MQTT176 -* **Name**: MQTTintegration NB/CB247 +* **Integration type**: UDP 248 +* **Name**: UDP Integration NB/CB 177 177 178 178 Click **Next** button. 179 179 252 + 180 180 [[image:add-integration-basic-settings.png||height="511" width="500"]] 181 181 182 182 183 183 **Uplink data converter:** 184 184 185 -* Click on the **Select existing** 186 -* **Uplink data converter**: Select **MQTTUplink Converter NB/CB258 +* Click on the ‘**Select existing**’ button. 259 +* Uplink data converter: Select ‘**UDP Uplink Converter NB/CB**’ from the dropdown list. 187 187 188 188 Click **Next** button. 189 189 190 -[[image:add-integration-uplink-data-converter.png||width="500"]] 191 191 264 +[[image:add-integration-uplink-data-converter.png||height="511" width="500"]] 192 192 266 + 193 193 **Downlink data converter:** 194 194 195 -* Click on the **Select existing** 196 -* **Downlink data converter**: Select **MQTTDownlink Converter NB/CB269 +* Click on the ‘**Select existing**’ button. 270 +* Downlink data converter: Select ‘**UDP Downlink Converter NB/CB**’ from the dropdown list. 197 197 272 + 198 198 Click **Next** button. 199 199 200 -[[image:add-integration-downlink-data-converter.png||height="510" width="500"]] 201 201 276 +[[image:add-integration-downlink-data-converter.png||height="512" width="500"]] 202 202 278 + 203 203 **Connection:** 204 204 205 -* **Host**: Cluster URL (Eg. 011731f7928541588a6cdfbbedfc63f4.s1.eu.hivemq.cloud) 206 -* **Port**: 8883 207 -* **Credentials**: Basic 208 -* **Enable SSL**: YES 209 -* **Username**: Username (from your HiveMQ Cloud Cluster with your credentials) 210 -* **Password:** Password (from your HiveMQ Cloud Cluster with your credentials) 211 -* **Topic:** tb/mqtt-integration-tutorial/sensors/+/telemetry (the + replaces any 'device name' and creates devices in the Entities -> Devices) 212 -* **QoS:** 0-At most once 213 -* **Clean session:** NO 214 -* **Retained**: NO 281 +**Port**: 11582 215 215 216 - Clickonthe**Checkconnection**buttontoverify the MQTTconnectionusingtheprovided parameters.283 +**Size of the buffer for inbound socket (in KB)**: 64 217 217 218 - [[image:add-integration-connection.png||width="500"]]285 +**Cache Size**: 10000000 219 219 287 +**Cache time to live in minutes**: 1440 220 220 221 -If the connection is successful, you will see the **Connected** message. 222 222 290 +Copy the two keys, **Integration key** and **Integration secret** into a text editor, as you will need them in the section ‘xxxxx’. 291 + 223 223 Click on the **Add** button. 224 224 225 -[[image:add-connection-success.png||height="511" width="500"]] 226 226 295 +[[image:add-integration-connection.png||height="511" width="500"]] 227 227 228 -You should see that the newly added integration is listed on the **Integrations** page. 229 229 230 -Since we haven't received data from a device yet, the integration **Status** is shown as **Pending.** 231 231 232 - [[image:integrations-list-added-pending.png]]299 += Verifying the receipt of data from the device = 233 233 301 +Connect **S31B-NB** to transfer information. If the integration was performed without errors, after the transmission of the first telemetry, a new device with the name “xxxxx” will appear in the Devices → All. Also, you can verify the input and output data, respectively, before and after conversion in Data converters → UDP Uplink Converter NB/CB → Events. 234 234 235 -= 5. Verifying the receipt of data from the device = 236 236 237 - 238 -On the terminal, issue the following MQTT command which simulates the device S31B-NB. 239 - 240 -{{code language="none"}} 241 -mosquitto_pub -d -q 1 -h mqtt.eu.thingsboard.cloud -p 1883 -t v1/devices/S31B-NB/telemetry -u "24vk3w9h7sqdld1me5eh" -m "{temperature:20}" 242 -{{/code}} 243 - 244 -If the integration was performed without errors, after the transmission of the first telemetry, a new device with the name “S31B-NB” will appear in the Devices → All. Also, you can verify the input and output data, respectively, before and after conversion in Data converters → UDP Uplink Converter NB/CB → Events. 245 - 304 +
- add-downlink-data-converter.png
-
- Author
-
... ... @@ -1,1 +1,0 @@ 1 -XWiki.pradeeka - Size
-
... ... @@ -1,1 +1,0 @@ 1 -175.2 KB - Content
- add-uplink-data-converter.png
-
- Author
-
... ... @@ -1,1 +1,0 @@ 1 -XWiki.pradeeka - Size
-
... ... @@ -1,1 +1,0 @@ 1 -174.1 KB - Content
- create-new-converter-menu.png
-
- Author
-
... ... @@ -1,1 +1,0 @@ 1 -XWiki.pradeeka - Size
-
... ... @@ -1,1 +1,0 @@ 1 -31.5 KB - Content
- data-converter-list-showing-uplink-dc.png
-
- Author
-
... ... @@ -1,1 +1,0 @@ 1 -XWiki.pradeeka - Size
-
... ... @@ -1,1 +1,0 @@ 1 -194.9 KB - Content
- data-converters-list-empty.png
-
- Author
-
... ... @@ -1,1 +1,0 @@ 1 -XWiki.pradeeka - Size
-
... ... @@ -1,1 +1,0 @@ 1 -260.7 KB - Content
- data-converters-list.png
-
- Author
-
... ... @@ -1,1 +1,0 @@ 1 -XWiki.pradeeka - Size
-
... ... @@ -1,1 +1,0 @@ 1 -212.2 KB - Content
- ThingsBoard-Data-Converters.png
-
- Author
-
... ... @@ -1,0 +1,1 @@ 1 +XWiki.pradeeka - Size
-
... ... @@ -1,0 +1,1 @@ 1 +100.3 KB - Content
- ThingsBoard-Device.png
-
- Author
-
... ... @@ -1,0 +1,1 @@ 1 +XWiki.pradeeka - Size
-
... ... @@ -1,0 +1,1 @@ 1 +225.5 KB - Content
- ThingsBoard-add-data-converter-downlink.png
-
- Author
-
... ... @@ -1,0 +1,1 @@ 1 +XWiki.pradeeka - Size
-
... ... @@ -1,0 +1,1 @@ 1 +128.6 KB - Content
- ThingsBoard-add-data-converter-uplink.png
-
- Author
-
... ... @@ -1,0 +1,1 @@ 1 +XWiki.pradeeka - Size
-
... ... @@ -1,0 +1,1 @@ 1 +128.6 KB - Content
- ThingsBoard-add-data-converter.png
-
- Author
-
... ... @@ -1,0 +1,1 @@ 1 +XWiki.pradeeka - Size
-
... ... @@ -1,0 +1,1 @@ 1 +128.6 KB - Content
- ThingsBoard-add-integration.png
-
- Author
-
... ... @@ -1,0 +1,1 @@ 1 +XWiki.pradeeka - Size
-
... ... @@ -1,0 +1,1 @@ 1 +128.6 KB - Content
- ThingsBoard-add-new-device.png
-
- Author
-
... ... @@ -1,0 +1,1 @@ 1 +XWiki.pradeeka - Size
-
... ... @@ -1,0 +1,1 @@ 1 +89.7 KB - Content
- ThingsBoard-new-data-converter.png
-
- Author
-
... ... @@ -1,0 +1,1 @@ 1 +XWiki.pradeeka - Size
-
... ... @@ -1,0 +1,1 @@ 1 +100.3 KB - Content
- add-integration-basic-settings.png
-
- Author
-
... ... @@ -1,0 +1,1 @@ 1 +XWiki.pradeeka - Size
-
... ... @@ -1,0 +1,1 @@ 1 +122.5 KB - Content
- add-integration-connection.png
-
- Author
-
... ... @@ -1,0 +1,1 @@ 1 +XWiki.pradeeka - Size
-
... ... @@ -1,0 +1,1 @@ 1 +124.4 KB - Content
- add-integration-downlink-data-converter.png
-
- Author
-
... ... @@ -1,0 +1,1 @@ 1 +XWiki.pradeeka - Size
-
... ... @@ -1,0 +1,1 @@ 1 +123.0 KB - Content
- add-integration-uplink-data-converter.png
-
- Author
-
... ... @@ -1,0 +1,1 @@ 1 +XWiki.pradeeka - Size
-
... ... @@ -1,0 +1,1 @@ 1 +120.7 KB - Content