Changes for page ThingsBoard
Last modified by Dilisi S on 2025/04/02 02:09
Summary
-
Page properties (1 modified, 0 added, 0 removed)
Details
- Page properties
-
- Content
-
... ... @@ -17,230 +17,75 @@ 17 17 The **NB series** devices end with the suffix **-NB**, and the **CB series** devices end with the suffix **-CB**. For example, **S31B-NB** is an **NB device**, and **S31-CB** is a **CB device**. 18 18 19 19 20 -= 2. Add New Device = 21 21 22 22 23 -First, we will add a device to simulate data using MQTT. This device does not represent a real physical device but serves as a common virtual device for all Dragino NB/CB devices. 24 24 25 - Intheleft navigation, click **Entities**andthenclick **Devices**.23 += 2. Data Converters = 26 26 27 -[[image:device-list-empty.png]] 28 28 26 +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. 29 29 30 -On the **Devices **page, click on the ‘**+**’ button, and then click on the **Add new device **from the dropdown menu. 31 31 32 - [[image:ThingsBoard-add-new-device.png||height="279"width="500"]]29 +== 2.1 Uplink == 33 33 34 34 35 - The**Add newdevice**windowappears.Namethedevice,for example '**VirtualNB/CB device**'.32 +In the left navigation, click **Integrations center**, and then click **Data converters**. 36 36 37 -Click on the **Next: Credentials** button. 38 38 39 -[[image:new-device-device-details.png||height="529" width="500"]] 40 40 36 +[[image:data-converters-list-empty.png]] 41 41 42 -Click the **Access token** button if it is not selected by default. 43 43 44 - CopytheAccesstoken**toa texteditor, as you willneedit in thesection'SendingdatafromanMQTT client'**.39 +On the **Data converters** page, click on the ‘**+**’ button, and then click on the **Create new converter** from the dropdown menu. 45 45 46 -Click on the **Add** button. 47 47 48 -[[image:new-device-access-token.png||height="528" width="500"]] 49 49 43 +[[image:create-new-converter-menu.png||height="259" width="500"]] 50 50 51 -Click on the **MQTT** button. 52 52 53 -Then, select the operating system you are going to use with the **Mosquitto MQTT Broker**. This example shows sending a command from a computer running **MacOS**. First, install the necessary client tools on your computer. 54 - 55 -Copy the MQTT pub command in the '**Execute the following command**' section. 56 - 57 -{{code language="none"}} 58 -mosquitto_pub -d -q 1 -h mqtt.eu.thingsboard.cloud -p 1883 -t v1/devices/me/telemetry -u "24vk3w9h7sqdld1me5eh" -m "{temperature:25}" 59 -{{/code}} 60 - 61 -Note that the **State** is still shown as **'Inactive'** in the **Latest telemetry** section. 62 - 63 -[[image:new-device-check-connectivity.png||height="522" width="500"]] 64 - 65 - 66 -On the terminal, enter the command you copied. This command sends the MQTT payload **{temperature:25}** as telemetry data from a virtual device named **'me'**. Of course, you can replace **'me'** with a device name or use the wildcard character **'+'** to match any device name. 67 - 68 - 69 -[[image:mqtt-command-1.png||height="228" width="700"]] 70 - 71 - 72 -If the command is successful, you can see the telemetry data you sent under the **Latest telemetry** section. Note that the **State** is now **'Active'** in the **Latest telemetry** section. 73 - 74 - 75 -[[image:new-device-telemetry-test.png||height="520" width="500"]] 76 - 77 - 78 -Send the same command again, only changing the **temperature** value, to see how the **Latest telemetry** section updates its data. 79 - 80 -Once you are done experimenting with this, close the window by clicking the **Close** button. 81 - 82 - 83 -[[image:mqtt-command-2.png||height="227" width="700"]] 84 - 85 - 86 - 87 -[[image:virtual-device-active.png]] 88 - 89 - 90 -= 3. Data Converters = 91 - 92 - 93 -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. 94 - 95 - 96 -== 3.1 Uplink == 97 - 98 - 99 -In the left navigation, click **Integrations center**, and then click **Data converters**. 100 - 101 -[[image:data-converter-list-page.png]] 102 - 103 - 104 -On the **Data converters** page, click on the ‘+’ button, and then click on the **Create new converter** from the dropdown menu. 105 - 106 -[[image:ThingsBoard-new-data-converter.png||height="282" width="500"]] 107 - 108 - 109 109 The **Add data converter** window will appear. Name it ‘**MQTT Uplink Converter NB/CB**’ and select the Type as **Uplink**. 110 110 111 -Click on the ** JavaScript**button. Now copy and paste the followingJavaScriptto the **Decoderfunction**section. This decoder function isvalidfor both NB and CB series devices.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. 112 112 113 113 {{code language="JavaScript"}} 114 -//Version: 0.1 51 +/** Decoder **/ 52 + 115 115 // decode payload to string 116 116 var payloadStr = decodeToString(payload); 55 +var data = JSON.parse(payloadStr); 117 117 57 +var deviceName = metadata.topic.split("/")[3]; 118 118 // decode payload to JSON 119 -var objdata = {}; 120 -var obj1 = {}; 121 -var data = decodeToJson(payload); 122 -var deviceName = data.IMEI; 123 -delete data.IMEI; 124 -var modelname = "Dragino " + data.Model; 125 -//var mod = data.mod 126 -delete data.Model; 127 -//delete data.mod 128 -var timestamp = new Date().getTime(); 59 +var deviceType = 'sensor'; 129 129 130 -for (var key in data) { 131 - 132 - if (Number(key)) { 133 - obj1[key] = data[key]; 134 - obj1[key][obj1[key].length - 1] = Number(new Date( 135 - obj1[key][obj1[key].length - 1])); 136 - 137 - } 138 -//Alec submitted25/02/25 139 -//turn old key into new 140 - else if (key === "Reading") { 141 - objdata["reading"] = data[key]; 142 - } else if (key === "work mode") { 143 - objdata["work_mode"] = data[key]; 144 - } else if (key === "hum") { 145 - objdata["humidity"] = data[key]; 146 - }else if (key === "hum2") { 147 - objdata["humidity2"] = data[key]; 148 - } else if (key === "hum3") { 149 - objdata["humidity3"] = data[key]; 150 - } else if (key === "tem") { 151 - objdata["temperature"] = data[key]; 152 - } else if (key === "tem2") { 153 - objdata["temperature2"] = data[key]; 154 - } else if (key === "tem3") { 155 - objdata["temperature3"] = data[key]; 156 - } else if (key === "DS18B20_Temp") { 157 - objdata["temperature_pro"] = data[key]; 158 - } else if (key === "ds18b20_temperature") { 159 - objdata["temperature_pro"] = data[key]; 160 - } else if (key === "DS18B20_temperature_pro") { 161 - objdata["temperature_pro"] = data[key]; 162 - } else if (key === "tdc send flag") { 163 - objdata["tdc_send_flag"] = data[key]; 164 - } else if (key === "trigger mode") { 165 - objdata["trigger_mode"] = data[key]; 166 - } else if (key === "soil dielectric constant") { 167 - objdata["soil_dielectric_constant"] = data[key]; 168 - } else if (key === "door open num") { 169 - objdata["door_open_num"] = data[key]; 170 - } else if (key === "door duration") { 171 - objdata["door_duration"] = data[key]; 172 - } else if (key === "count time") { 173 - objdata["count_time"] = data[key]; 174 - } else if (key === "last open time2") { 175 - objdata["last_open_time2"] = data[key]; 176 - } else if (key === "last open time3") { 177 - objdata["last_open_time3"] = data[key]; 178 - } 179 -//Alec submitted25/02/25 180 - else { 181 - objdata[key] = data[key] 182 - } 183 -} 184 -var listdata = [{ 185 - "ts": timestamp, 186 - "values": objdata 187 -}] 188 -for (var key1 in obj1) { 189 - if (modelname == "Dragino RS485-NB") { 190 - listdata.push({ 191 - "ts": obj1[key1][obj1[key1].length - 1], 192 - "values": { 193 - "Payload": obj1[key1][0], 194 - } 195 - }) 196 - } else { 197 - listdata.push({ 198 - "ts": obj1[key1][obj1[key1].length - 1], 199 - "values": { 200 - "values": obj1[key1] 201 - }, 202 - }) 203 - } 204 -} 61 +// Result object with device attributes/telemetry data 205 205 var result = { 206 - 207 207 deviceName: deviceName, 208 - deviceType: modelname,64 + deviceType: deviceType, 209 209 attributes: { 210 - model: modelname, 211 - //customerName: "NB-CB", 212 - //groupName: "NB-CB", 213 - //integrationName: metadata['integrationName'] 214 - 66 + integrationName: metadata['integrationName'], 215 215 }, 216 - telemetry: listdata 217 -} 68 + telemetry: { 69 + temperature: data.temperature, 70 + humidity: data.humidity, 71 + } 72 +}; 218 218 219 -function decodeToString(payload) { 220 - return String.fromCharCode.apply(String, payload); 221 -} 74 +/** Helper functions 'decodeToString' and 'decodeToJson' are already built-in **/ 222 222 223 -function decodeToJson(payload) { 224 - // covert payload to string. 225 - var str = decodeToString(payload); 226 - 227 - // parse string to JSON 228 - var data = JSON.parse(str); 229 - return data; 230 -} 231 - 232 232 return result; 233 - 234 234 {{/code}} 235 235 236 236 237 237 Click on the **Add** button. 238 238 239 -[[image:uplink-data-converter.png||height="529" width="500"]] 240 240 241 241 242 - You should see that thenewlyadded **uplink** is listed onthe**DataConverters** page.84 +[[image:add-uplink-data-converter.png||height="529" width="500"]] 243 243 86 + 87 +You should see that the newly added **MQTT Uplink converter **NB/CB is listed on the **Data Converters** page. 88 + 244 244 [[image:data-converter-list-showing-uplink-dc.png]] 245 245 246 246 ... ... @@ -254,32 +254,41 @@ 254 254 255 255 The **Add data converter** window will appear. Name it ‘**MQTT Downlink Converter NB/CB**’ and select the Type as **Downlink**. 256 256 257 -Click on the ** JavaScript** button. Now copy and paste the followingJavaScriptto the **Encoderfunction**section.validfor both NB and CB series devices.102 +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. 258 258 259 259 260 260 {{code language="JavaScript"}} 261 -function hexToBase64(hexString) { 262 - // 将16进制字符串两个字符转换为一个字节 263 - var bytes = hexString.match(/.{2}/g); 264 - // 对每个字节进行解析,并转换为对应的字符 265 - var binaryString = bytes.map(function(byte) { 266 - return String.fromCharCode(parseInt(byte, 16)); 267 - }).join(''); 268 - 269 - // 使用btoa进行base64编码 270 - return btoa(binaryString); 271 -} 106 +// Encode downlink data from incoming Rule Engine message 272 272 108 +// msg - JSON message payload downlink message json 109 +// msgType - type of message, for ex. 'ATTRIBUTES_UPDATED', 'POST_TELEMETRY_REQUEST', etc. 110 +// metadata - list of key-value pairs with additional data about the message 111 +// integrationMetadata - list of key-value pairs with additional data defined in Integration executing this converter 112 + 113 +/** Encoder **/ 114 + 115 +var data = {}; 116 + 117 +// Process data from incoming message and metadata 118 + 119 +data.tempFreq = msg.temperatureUploadFrequency; 120 +data.humFreq = msg.humidityUploadFrequency; 121 + 122 +data.devSerialNumber = metadata['ss_serialNumber']; 123 + 273 273 // Result object with encoded downlink payload 274 274 var result = { 126 + 275 275 // downlink data content type: JSON, TEXT or BINARY (base64 format) 276 - contentType: " BINARY",128 + contentType: "JSON", 277 277 278 278 // downlink data 279 - data: hexToBase64(metadata.shared_value)131 + data: JSON.stringify(data), 280 280 281 281 // Optional metadata object presented in key/value format 282 - //metadata: {} 134 + metadata: { 135 + topic: metadata['deviceType']+'/'+metadata['deviceName']+'/upload' 136 + } 283 283 284 284 }; 285 285 ... ... @@ -289,17 +289,20 @@ 289 289 290 290 Click on the **Add** button. 291 291 292 -[[image:downlink-data-converter.png||height="530" width="500"]] 293 293 294 294 295 - You should see that thenewlyadded**downlink** is listed onthe**DataConverters** page.148 +[[image:add-downlink-data-converter.png||height="529" width="500"]] 296 296 297 -[[image:data-converter-list.png]] 298 298 151 +You should see that the newly added **MQTT Downlink** Converter NB/CB is listed on the **Data Converters** page. 299 299 300 -= 4. Add Integration = 301 301 302 302 155 +[[image:data-converters-list.png]] 156 + 157 += 3. Add Integration = 158 + 159 + 303 303 In the left navigation, click **Integrations center**, and then click **Integrations**. 304 304 305 305 On the **Integrations** page, click on the '**+**' button. ... ... @@ -344,13 +344,16 @@ 344 344 345 345 **Connection:** 346 346 347 -* **Host**: mqtt.eu.thingsboard.cloud (Thisisthehostnameyoucopiedrom theevice - Seesection xxxxx for moreinformation)348 -* **Port**: 1883(This is the port number you copied from the device - See section xxxxx for more information)204 +* **Host**: Cluster URL (Eg. 011731f7928541588a6cdfbbedfc63f4.s1.eu.hivemq.cloud) 205 +* **Port**: 8883 349 349 * **Credentials**: Basic 350 -* **Username**: Access token (This is the access token you copied from the device) 351 -* **Password** - Leave it as blank 352 -* **Topic** - v1/devices/+/telemetry (sightly modify the topic 'v1/devices/me/telemetry' you copied from the device to enable receiving data from any 'device name') 353 -* **QoS** - 0-At most once 207 +* **Enable SSL**: YES 208 +* **Username**: Username (from your HiveMQ Cloud Cluster with your credentials) 209 +* **Password:** Password (from your HiveMQ Cloud Cluster with your credentials) 210 +* **Topic:** tb/mqtt-integration-tutorial/sensors/+/telemetry (the + replaces any 'device name' and creates devices in the Entities -> Devices) 211 +* **QoS:** 0-At most once 212 +* **Clean session:** NO 213 +* **Retained**: NO 354 354 355 355 Click on the **Check connection** button to verify the MQTT connection using the provided parameters. 356 356