Changes for page ThingsBoard
Last modified by Dilisi S on 2025/04/15 23:13
Summary
-
Page properties (1 modified, 0 added, 0 removed)
Details
- Page properties
-
- Content
-
... ... @@ -164,32 +164,13 @@ 164 164 [[image:ins1.png||height="310" width="500"]] 165 165 166 166 167 -= 3. CreatingDevices =167 += 3. Data Converters = 168 168 169 169 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 - 172 - 173 -In the left navigation, click Entities -> Devices. 174 - 175 -Click the **Add Device** button (the button with the **+** sign), and from the dropdown menu, click **Add new device**. 176 - 177 -In the **Add new device** dialog box, enter the device name in the **Name** text box. For example, we will use **Device A**. 178 - 179 -Click the **Add** button. 180 - 181 -Skip the **connectivity testing** by clicking the **Close** button. 182 - 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. 184 - 185 - 186 -= 4. Data Converters = 187 - 188 - 189 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. 190 190 191 191 192 -== 4.1 Uplink ==173 +== 3.1 Uplink == 193 193 194 194 195 195 In the left navigation, click **Integrations center**, and then click **Data converters**. ... ... @@ -207,76 +207,135 @@ 207 207 208 208 The **Add data converter** window will appear. Name it ‘**MQTT Uplink Converter NB/CB**’ and select the Type as **Uplink**. 209 209 210 -Click on the ** TBEL** buttonif it has not been selected by default.191 +Click on the **JavaScript** button. 211 211 212 - The defaultTBELfunction isshownbelow.193 +Delete the default decoder function in the code editor. Now copy and paste the following decoder function written in **JavaScript** in to the **code editor**. This decoder function is compatible for both NB and CB series devices. 213 213 214 214 215 215 {{code language="JavaScript"}} 216 -// Decode an uplink message from a buffer 217 -// payload - array of bytes 218 -// metadata - key/value object 219 - 220 -/** Decoder **/ 221 - 197 +//Version: 0.1 222 222 // decode payload to string 223 223 var payloadStr = decodeToString(payload); 224 224 225 225 // decode payload to JSON 226 -// var data = decodeToJson(payload); 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(); 227 227 228 -var deviceName = 'Device A'; 229 -var deviceType = 'thermostat'; 230 -var customerName = 'Customer C'; 231 -var groupName = 'thermostat devices'; 232 -var manufacturer = 'Example corporation'; 233 -// use assetName and assetType instead of deviceName and deviceType 234 -// to automatically create assets instead of devices. 235 -// var assetName = 'Asset A'; 236 -// var assetType = 'building'; 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])); 237 237 238 -// Result object with device/asset attributes/telemetry data 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 +} 239 239 var result = { 240 -// Use deviceName and deviceType or assetName and assetType, but not both. 241 - deviceName: deviceName, 242 - deviceType: deviceType, 243 -// assetName: assetName, 244 -// assetType: assetType, 245 -// customerName: customerName, 246 - groupName: groupName, 247 - attributes: { 248 - model: 'Model A', 249 - serialNumber: 'SN111', 250 - integrationName: metadata['integrationName'], 251 - manufacturer: manufacturer 252 - }, 253 - telemetry: { 254 - temperature: 42, 255 - humidity: 80, 256 - rawData: payloadStr 257 - } 258 -}; 259 259 260 -/** Helper functions 'decodeToString' and 'decodeToJson' are already built-in **/ 290 + deviceName: deviceName, 291 + deviceType: modelname, 292 + attributes: { 293 + model: modelname, 294 + //customerName: "NB-CB", 295 + //groupName: "NB-CB", 296 + //integrationName: metadata['integrationName'] 261 261 262 -return result; 263 -{{/code}} 298 + }, 299 + telemetry: listdata 300 +} 264 264 265 -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. 302 +function decodeToString(payload) { 303 + return String.fromCharCode.apply(String, payload); 304 +} 266 266 267 -For example, if your device name is **Device B**, you can change **Device A** to **Device B**. 306 +function decodeToJson(payload) { 307 + // covert payload to string. 308 + var str = decodeToString(payload); 268 268 310 + // parse string to JSON 311 + var data = JSON.parse(str); 312 + return data; 313 +} 269 269 270 -{{code language="JavaScript"}} 271 -var deviceName = 'Device A'; 272 -var deviceType = 'thermostat'; 273 -var customerName = 'Customer C'; 274 -var groupName = 'thermostat devices'; 275 -var manufacturer = 'Example corporation'; 315 +return result; 276 276 {{/code}} 277 277 278 278 279 - Once you modify the decoder function, click on the **Add** button.319 +Click on the **Add** button. 280 280 281 281 282 282 [[image:mqtt-uplink.png||width="500"]] ... ... @@ -289,9 +289,13 @@ 289 289 [[image:data-converter-list-showing-uplink-dc.png]] 290 290 291 291 292 -= 5. Add Integration = 293 293 294 294 334 + 335 + 336 += 4. Add Integration = 337 + 338 + 295 295 In the left navigation, click **Integrations center**, and then click **Integrations**. 296 296 297 297 ... ... @@ -345,13 +345,13 @@ 345 345 346 346 **Connection:** 347 347 348 -* **Host**: Cluster URL (Eg. **//011731f7xxxxxxxxxxxfbbedfc63f4.s1.eu.hivemq.cloud//**)392 +* **Host**: Cluster URL (Eg. 011731f7xxxxxxxxxxxfbbedfc63f4.s1.eu.hivemq.cloud) 349 349 * **Port**: 8883 350 350 * **Credentials**: Basic 351 351 * **Enable SSL**: YES 352 352 * **Username**: Username (from your HiveMQ Cloud Cluster with your credentials) 353 353 * **Password:** Password (from your HiveMQ Cloud Cluster with your credentials) 354 -* **Topic: v1/devices/me/telemetry** (The topic can be anything ;you canevenuse just the device name.For example,you can use your devicename here, such as devices/a/telemetry.)398 +* **Topic: v1/devices/me/telemetry** (The topic can be anything, even you can use just the device name, for example ts02-nb) 355 355 * **QoS:** 0-At most once 356 356 357 357 [[image:add-integration-connection.png||height="511" width="500"]] ... ... @@ -384,13 +384,14 @@ 384 384 Since we haven't received data from a device yet, the integration **Status** is shown as **Pending.** 385 385 386 386 431 + 387 387 [[image:new-integration-pending.png]] 388 388 389 389 390 -= 6. Verifying the receipt of data from virtual devices =435 += 5. Verifying the receipt of data from virtual devices = 391 391 392 392 393 -== 6.1 How does it work? ==438 +== 5.1 How does it work? == 394 394 395 395 396 396 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. ... ... @@ -427,7 +427,7 @@ 427 427 [[image:new-device.png]] 428 428 429 429 430 -== 6.3 Viewing messages ==475 +== 5.3 Viewing messages == 431 431 432 432 433 433 Go back to the **Integrations** page. ... ... @@ -467,7 +467,7 @@ 467 467 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. 468 468 469 469 470 -= 7. Creating a Dashboard =515 += 6. Creating a Dashboard = 471 471 472 472 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. 473 473 ... ... @@ -550,7 +550,7 @@ 550 550 [[image:timeseries-4.png||height="316" width="700"]] 551 551 552 552 553 -= 8. Configure NB-IoT Sensor =598 += 7. Configure NB-IoT Sensor = 554 554 555 555 556 556 Now, let's experiment with sending data to ThingsBoard using a real NB-IoT device. For example, we will use the **TS01-NB**. ... ... @@ -561,7 +561,7 @@ 561 561 **AT Commands** 562 562 563 563 * **AT+PRO=3,3 **~/~/ Use MQTT to connect to ThingsBoard. Payload Type set to 3. 564 -* **AT+SUBTOPIC=<MQTT subscribe topic> Eg: TS01-NB**609 +* **AT+SUBTOPIC=<MQTT subscribe topic> ** 565 565 * **AT+PUBTOPIC=<MQTT publish topic> Eg: TS01-NB** 566 566 * **AT+CLIENT=null** 567 567 * **AT+UNAME=<MQTT Username>**