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 (2 modified, 4 added, 0 removed)
Details
- Page properties
-
- Content
-
... ... @@ -164,240 +164,151 @@ 164 164 [[image:ins1.png||height="310" width="500"]] 165 165 166 166 167 -= 3. Data Converters =167 += 3. Creating Devices = 168 168 169 169 170 - In **ThingsBoard**, **DataConverters** arecomponents used totransformincomingoutgoingdata betweendifferentformats,typicallyto convertrawtelemetrydatafromdevicesintoastructuredformatthatThingsBoardcanunderstand,orviceversa.170 +First, you need to create devices in ThingsBoard to represent your physical devices. For example, you can name it **Device A**, and the second device could be **Device B** or any name you prefer. The device name should be unique within the **Devices** space. 171 171 172 172 173 - ==3.1Uplink==173 +In the left navigation, click Entities -> Devices. 174 174 175 +Click the **Add Device** button (the button with the **+** sign), and from the dropdown menu, click **Add new device**. 175 175 176 -In the leftnavigation,click **Integrationscenter**,andthen click**Dataconverters**.177 +In the **Add new device** dialog box, enter the device name in the **Name** text box. For example, we will use **Device A**. 177 177 179 +Click the **Add** button. 178 178 179 - [[image:data-converters-list-empty.png]]181 +Skip the **connectivity testing** by clicking the **Close** button. 180 180 183 +The device is created and listed on the **Devices** page. Note that its initial state is **Inactive** because it has not received any data yet. 181 181 182 -On the **Data converters** page, click on the ‘**+**’ button, and then click on the **Create new converter** from the dropdown menu. 183 183 186 += 4. Data Converters = 184 184 185 185 186 - [[image:create-new-converter-menu.png||height="259"width="500"]]189 +In **ThingsBoard**, **Data Converters** are components 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. 187 187 188 188 189 - The**Add data converter** window will appear.Name it ‘**MQTTUplinkConverter NB/CB**’ and select the Type as **Uplink**.192 +== 4.1 Uplink == 190 190 191 -Click on the **JavaScript** button. 192 192 193 - Deletethedefaultdecoder functionin thecode editor. Nowcopyand pastethe followingdecoderfunctionwrittenin **JavaScript**intothe**code editor**. This decoderfunctioniscompatibleforboth NB and CB seriesdevices.195 +In the left navigation, click **Integrations center**, and then click **Data converters**. 194 194 195 195 196 -{{code language="JavaScript"}} 197 -//Version: 0.1 198 -// decode payload to string 199 -var payloadStr = decodeToString(payload); 198 +[[image:data-converters-list-empty.png]] 200 200 201 -// decode payload to JSON 202 -var objdata = {}; 203 -var obj1 = {}; 204 -var data = decodeToJson(payload); 205 -var deviceName = data.IMEI; 206 -delete data.IMEI; 207 -var modelname = "Dragino " + data.Model; 208 -//var mod = data.mod 209 -delete data.Model; 210 -//delete data.mod 211 -var timestamp = new Date().getTime(); 212 212 213 -for (var key in data) { 214 - 215 - if (Number(key)) { 216 - obj1[key] = data[key]; 217 - obj1[key][obj1[key].length - 1] = Number(new Date( 218 - obj1[key][obj1[key].length - 1])); 201 +On the **Data converters** page, click on the ‘**+**’ button, and then click on the **Create new converter** from the dropdown menu. 219 219 220 - } 221 -//Alec submitted25/02/25 222 -//turn old key into new 223 - else if (key === "Reading") { 224 - objdata["reading"] = data[key]; 225 - } else if (key === "work mode") { 226 - objdata["work_mode"] = data[key]; 227 - } else if (key === "hum") { 228 - objdata["humidity"] = data[key]; 229 - }else if (key === "hum2") { 230 - objdata["humidity2"] = data[key]; 231 - } else if (key === "hum3") { 232 - objdata["humidity3"] = data[key]; 233 - } else if (key === "tem") { 234 - objdata["temperature"] = data[key]; 235 - } else if (key === "tem2") { 236 - objdata["temperature2"] = data[key]; 237 - } else if (key === "tem3") { 238 - objdata["temperature3"] = data[key]; 239 - } else if (key === "DS18B20_Temp") { 240 - objdata["temperature_pro"] = data[key]; 241 - } else if (key === "ds18b20_temperature") { 242 - objdata["temperature_pro"] = data[key]; 243 - } else if (key === "DS18B20_temperature_pro") { 244 - objdata["temperature_pro"] = data[key]; 245 - } else if (key === "tdc send flag") { 246 - objdata["tdc_send_flag"] = data[key]; 247 - } else if (key === "trigger mode") { 248 - objdata["trigger_mode"] = data[key]; 249 - } else if (key === "soil dielectric constant") { 250 - objdata["soil_dielectric_constant"] = data[key]; 251 - } else if (key === "door open num") { 252 - objdata["door_open_num"] = data[key]; 253 - } else if (key === "door duration") { 254 - objdata["door_duration"] = data[key]; 255 - } else if (key === "count time") { 256 - objdata["count_time"] = data[key]; 257 - } else if (key === "last open time2") { 258 - objdata["last_open_time2"] = data[key]; 259 - } else if (key === "last open time3") { 260 - objdata["last_open_time3"] = data[key]; 261 - } 262 -//Alec submitted25/02/25 263 - else { 264 - objdata[key] = data[key] 265 - } 266 -} 267 -var listdata = [{ 268 - "ts": timestamp, 269 - "values": objdata 270 -}] 271 -for (var key1 in obj1) { 272 - if (modelname == "Dragino RS485-NB") { 273 - listdata.push({ 274 - "ts": obj1[key1][obj1[key1].length - 1], 275 - "values": { 276 - "Payload": obj1[key1][0], 277 - } 278 - }) 279 - } else { 280 - listdata.push({ 281 - "ts": obj1[key1][obj1[key1].length - 1], 282 - "values": { 283 - "values": obj1[key1] 284 - }, 285 - }) 286 - } 287 -} 288 -var result = { 289 289 290 - deviceName: deviceName, 291 - deviceType: modelname, 292 - attributes: { 293 - model: modelname, 294 - //customerName: "NB-CB", 295 - //groupName: "NB-CB", 296 - //integrationName: metadata['integrationName'] 297 297 298 - }, 299 - telemetry: listdata 300 -} 205 +[[image:create-new-converter-menu.png||height="259" width="500"]] 301 301 302 -function decodeToString(payload) { 303 - return String.fromCharCode.apply(String, payload); 304 -} 305 305 306 -function decodeToJson(payload) { 307 - // covert payload to string. 308 - var str = decodeToString(payload); 208 +The **Add data converter** window will appear. Name it ‘**MQTT Uplink Converter NB/CB**’ and select the Type as **Uplink**. 309 309 310 - // parse string to JSON 311 - var data = JSON.parse(str); 312 - return data; 313 -} 210 +Click on the **TBEL** button if it has not been selected by default. 314 314 315 -return result; 316 -{{/code}} 212 +Modify the default TBEL function to match with your device as described below: 317 317 318 318 319 - Clickonhe**Add** button.215 +~1. Uncomment line 11: 320 320 217 +var data = decodeToJson(payload) 321 321 322 -[[image: mqtt-uplink.png||width="500"]]219 +[[image:Screenshot 2025-03-26 at 18.15.08.png||height="219" width="500"]] 323 323 324 324 222 +3. Modify the telemetry section to allow parsed data to be assigned to the fields. 325 325 326 -You should see that the newly added **MQTT Uplink converter **NB/CB is listed on the **Data Converters** page. 224 +telemetry: { 225 + temperature: data.temperature, 226 + humidity: data.humidity, 227 + rawData: payloadStr 228 + } 327 327 328 328 329 -[[image:data-converter-list-showing-uplink-dc.png]] 330 330 331 - 332 -== 3.2 Downlink == 333 - 334 - 335 -On the **Data converters** page, click on the ‘**+**’ button, and then click on the **Create new converter** from the dropdown menu. 336 - 337 - 338 -[[image:create-new-converter-menu.png||width="500"]] 339 - 340 - 341 - 342 -The **Add data converter** window will appear. Name it ‘**MQTT Downlink Converter NB/CB**’ and select the Type as **Downlink**. 343 - 344 -Click on the **TBEL** button if not selected it by default. Now copy and paste the following encoder function written in **TBEL (ThingsBoard Expression Language)** in to the **code editor**. This encoder function is compatible for both NB and CB series devices. 345 - 346 - 347 347 {{code language="JavaScript"}} 348 -// Encode downlink data from incoming Rule Engine message 233 +// Decode an uplink message from a buffer 234 +// payload - array of bytes 235 +// metadata - key/value object 349 349 350 -// msg - JSON message payload downlink message json 351 -// msgType - type of message, for ex. 'ATTRIBUTES_UPDATED', 'POST_TELEMETRY_REQUEST', etc. 352 -// metadata - list of key-value pairs with additional data about the message 353 -// integrationMetadata - list of key-value pairs with additional data defined in Integration executing this converter 237 +/** Decoder **/ 354 354 355 -/** Encoder **/ 239 +// decode payload to string 240 +var payloadStr = decodeToString(payload); 356 356 357 -var data = {}; 242 +// decode payload to JSON 243 +var data = decodeToJson(payload); 358 358 359 -// Process data from incoming message and metadata 245 +var deviceName = 'Device B'; 246 +var deviceType = 'thermostat'; 247 +var customerName = 'Customer C'; 248 +var groupName = 'thermostat devices'; 249 +var manufacturer = 'Example corporation'; 250 +// use assetName and assetType instead of deviceName and deviceType 251 +// to automatically create assets instead of devices. 252 +// var assetName = 'Asset A'; 253 +// var assetType = 'building'; 360 360 361 -data.tempFreq = msg.temperatureUploadFrequency; 362 -data.humFreq = msg.humidityUploadFrequency; 363 - 364 -data.devSerialNumber = metadata['ss_serialNumber']; 365 - 366 -// Result object with encoded downlink payload 255 +// Result object with device/asset attributes/telemetry data 367 367 var result = { 257 +// Use deviceName and deviceType or assetName and assetType, but not both. 258 + deviceName: deviceName, 259 + deviceType: deviceType, 260 +// assetName: assetName, 261 +// assetType: assetType, 262 +// customerName: customerName, 263 + groupName: groupName, 264 + attributes: { 265 + model: 'Model A', 266 + serialNumber: 'SN111', 267 + integrationName: metadata['integrationName'], 268 + manufacturer: manufacturer 269 + }, 270 + telemetry: { 271 + temperature: data.temperature, 272 + humidity: data.humidity, 273 + rawData: payloadStr 274 + } 275 +}; 368 368 369 - // downlink data content type: JSON, TEXT or BINARY (base64 format) 370 - contentType: "JSON", 277 +/** Helper functions 'decodeToString' and 'decodeToJson' are already built-in **/ 371 371 372 - // downlinkdata373 - ata: JSON.stringify(data),279 +return result; 280 +{{/code}} 374 374 375 - // Optional metadata object presented in key/value format 376 - metadata: { 377 - topic: metadata['deviceType']+'/'+metadata['deviceName']+'/upload' 378 - } 282 +We use the same decoder function for all our devices. However, you need to modify a few things for each device. Among these, **deviceName** is a **mandatory** field. You should assign a device name to the **deviceName** field that matches the name of your device in the **Devices** section. 379 379 380 - };284 +For example, if your device name is **Device B**, you can change **Device A** to **Device B**. 381 381 382 -return result; 286 + 287 +{{code language="JavaScript"}} 288 +var deviceName = 'Device A'; 289 +var deviceType = 'thermostat'; 290 +var customerName = 'Customer C'; 291 +var groupName = 'thermostat devices'; 292 +var manufacturer = 'Example corporation'; 383 383 {{/code}} 384 384 385 385 386 - Click on the **Add** button.296 +Once you modify the decoder function, click on the **Add** button. 387 387 388 388 389 -[[image: add-downlink-data-converter.png||height="529"width="500"]]299 +[[image:mqtt-uplink.png||width="500"]] 390 390 391 391 392 -You should see that the newly added **MQTT Downlink** Converter NB/CB is listed on the **Data Converters** page. 393 393 303 +You should see that the newly added **MQTT Uplink converter **NB/CB is listed on the **Data Converters** page. 394 394 395 -[[image:data-converters-list.png]] 396 396 306 +[[image:data-converter-list-showing-uplink-dc.png]] 397 397 398 -= 4. Add Integration = 399 399 309 += 5. Add Integration = 400 400 311 + 401 401 In the left navigation, click **Integrations center**, and then click **Integrations**. 402 402 403 403 ... ... @@ -438,24 +438,26 @@ 438 438 439 439 **Downlink data converter:** 440 440 441 -* Click on the **Select existing** button. 442 -* **Downlink data converter**: Select **MQTT Downlink Converter NB/CB **from the dropdown list. 352 +Dragino NB/CB devices don't require a downlink data converter to decode their payloads, so you can skip this step. 443 443 444 -Click **Next** button.354 +* Click on the **Skip **button in the Downlink data converter section. 445 445 356 +Click **Skip** button. 446 446 447 -[[image:add-integration-downlink-data-converter.png||height="511" width="500"]] 448 448 359 +[[image:integration-dl-skip.png||height="511" width="500"]] 449 449 361 + 362 + 450 450 **Connection:** 451 451 452 -* **Host**: Cluster URL (Eg. 011731f7xxxxxxxxxxxfbbedfc63f4.s1.eu.hivemq.cloud) 365 +* **Host**: Cluster URL (Eg. **//011731f7xxxxxxxxxxxfbbedfc63f4.s1.eu.hivemq.cloud//**) 453 453 * **Port**: 8883 454 454 * **Credentials**: Basic 455 455 * **Enable SSL**: YES 456 456 * **Username**: Username (from your HiveMQ Cloud Cluster with your credentials) 457 457 * **Password:** Password (from your HiveMQ Cloud Cluster with your credentials) 458 -* **Topic: v1/devices/ +/telemetry** (the+ replacesany'device name'will create a deviceintheEntities->Devices)371 +* **Topic: v1/devices/me/telemetry** (The topic can be anything; you can even use just the device name. For example, you can use your device name here, such as devices/a/telemetry.) 459 459 * **QoS:** 0-At most once 460 460 461 461 [[image:add-integration-connection.png||height="511" width="500"]] ... ... @@ -488,14 +488,13 @@ 488 488 Since we haven't received data from a device yet, the integration **Status** is shown as **Pending.** 489 489 490 490 491 - 492 492 [[image:new-integration-pending.png]] 493 493 494 494 495 -= 5. Verifying the receipt of data from virtual devices =407 += 6. Verifying the receipt of data from virtual devices = 496 496 497 497 498 -== 5.1 How does it work? ==410 +== 6.1 How does it work? == 499 499 500 500 501 501 We use the Mosquitto MQTT client to simulate MQTT messages, acting as a virtual device. First, install the Mosquitto client on your computer from [[this link>>url:https://mosquitto.org/download/]]. The Mosquitto client publishes messages to the MQTT broker (HiveMQ) on a specified MQTT topic. ThingsBoard subscribes to these messages using the same topic. ... ... @@ -532,7 +532,7 @@ 532 532 [[image:new-device.png]] 533 533 534 534 535 -== 5.3 Viewing messages ==447 +== 6.3 Viewing messages == 536 536 537 537 538 538 Go back to the **Integrations** page. ... ... @@ -572,7 +572,7 @@ 572 572 Now, you have successfully tested your integration with a simulated uplink payload and verified that it is received by ThingsBoard, and the device is provisioned. 573 573 574 574 575 -= 6. Creating a Dashboard =487 += 7. Creating a Dashboard = 576 576 577 577 ThingsBoard **Dashboards** provide a powerful way to visualize and monitor real-time and historical data from connected devices. They allow users to create interactive, customizable panels displaying telemetry data, device status, and other key metrics. With a variety of widgets, including charts, maps, and tables, dashboards help users gain insights, track trends, and manage IoT deployments efficiently. 578 578 ... ... @@ -582,8 +582,7 @@ 582 582 583 583 First simulate a few messages using MQTT. This time, we have added the 'humidity' field to the payload. Eg: 584 584 585 -{{code language="none"}}mosquitto_pub -d -q 1 -h 011731f7928xxxxx.s1.eu.hivemq.cloud -p 8883 -t "v1/devices/me/telemetry" -u "xxxxx" -P "xxxxx" -m '{"IMEI": "S31B-NB", "temperature": 22, "humidity":80}' 586 -{{/code}} 497 +{{code language="none"}}mosquitto_pub -d -q 1 -h 011731f7928xxxxx.s1.eu.hivemq.cloud -p 8883 -t "v1/devices/me/telemetry" -u "xxxxx" -P "xxxxx" -m '{"IMEI": "S31B-NB", "temperature": 22, "humidity":80}'{{/code}} 587 587 588 588 589 589 In **ThingsBoard**, from the left navigation menu, click **Dashboards**. Then, click the **+** button and select **Create new dashboard** from the dropdown menu. ... ... @@ -656,10 +656,10 @@ 656 656 [[image:timeseries-4.png||height="316" width="700"]] 657 657 658 658 659 -= 7. Configure NB-IoT Sensor =570 += 8. Configure NB-IoT Sensor = 660 660 661 661 662 -Now, let's experiment with sending data to ThingsBoard using a real NB-IoT device. For example, we will use the **S 31B-NB**.573 +Now, let's experiment with sending data to ThingsBoard using a real NB-IoT device. For example, we will use the **TS01-NB**. 663 663 664 664 First, configure the NB-IoT device with the necessary MQTT settings using AT commands. Below is a list of AT commands you can use. 665 665 ... ... @@ -667,7 +667,7 @@ 667 667 **AT Commands** 668 668 669 669 * **AT+PRO=3,3 **~/~/ Use MQTT to connect to ThingsBoard. Payload Type set to 3. 670 -* **AT+SUBTOPIC=<MQTT subscribe topic> ** 581 +* **AT+SUBTOPIC=<MQTT subscribe topic> Eg: TS01-NB** 671 671 * **AT+PUBTOPIC=<MQTT publish topic> Eg: TS01-NB** 672 672 * **AT+CLIENT=null** 673 673 * **AT+UNAME=<MQTT Username>** ... ... @@ -675,10 +675,15 @@ 675 675 * **AT+SERVADDR=<Broker address, Port>** 676 676 677 677 Test your uplink by pressing the ACT button for 1 second. 589 + 678 678 679 679 680 680 The following image shows the uplink payload of a real Dragino device. The publish topic is **TS01-NB**, and the device name is **861275077962896**, which is represented by the **IMEI**. 681 681 594 +{{info}} 595 +The ThingsBoard uses the device's IMEI number included in the payload to create a device in the Devices section. 596 +{{/info}} 597 + 682 682 [[image:image-4.png]] 683 683 684 684
- Screenshot 2025-03-16 at 18.39.12.png
-
- Size
-
... ... @@ -1,1 +1,1 @@ 1 -2 77.0KB1 +211.9 KB - Content
- add-integration-connection.png
-
- Size
-
... ... @@ -1,1 +1,1 @@ 1 -15 3.2KB1 +158.1 KB - Content
- Screenshot 2025-03-26 at 18.15.08.png
-
- Author
-
... ... @@ -1,0 +1,1 @@ 1 +XWiki.pradeeka - Size
-
... ... @@ -1,0 +1,1 @@ 1 +92.2 KB - Content
- Screenshot 2025-03-26 at 19.47.52.png
-
- Author
-
... ... @@ -1,0 +1,1 @@ 1 +XWiki.pradeeka - Size
-
... ... @@ -1,0 +1,1 @@ 1 +168.4 KB - Content
- Screenshot 2025-03-26 at 19.49.31.png
-
- Author
-
... ... @@ -1,0 +1,1 @@ 1 +XWiki.pradeeka - Size
-
... ... @@ -1,0 +1,1 @@ 1 +133.0 KB - Content
- integration-dl-skip.png
-
- Author
-
... ... @@ -1,0 +1,1 @@ 1 +XWiki.pradeeka - Size
-
... ... @@ -1,0 +1,1 @@ 1 +105.5 KB - Content