Show last authors
| author | version | line-number | content |
|---|---|---|---|
| 1 | = **1 General Script Demo** = | ||
| 2 | |||
| 3 | == **1.1 Address Operation:Write/Read data from address A to B** == | ||
| 4 | |||
| 5 | ((( | ||
| 6 | For example:transfer D2 to D0 | ||
| 7 | ))) | ||
| 8 | |||
| 9 | (% style="text-align:center" %) | ||
| 10 | [[image:1624245865976-320.png||height="182" width="1000" class="img-thumbnail"]] | ||
| 11 | |||
| 12 | Depend on diffferent format of data.V-Box use different script functions. | ||
| 13 | for example. addr_setshort(addr,num) Function: Write 16-bit signed decimal address | ||
| 14 | addr_getshort(addr) Function:Read 16-bit signed decimal address | ||
| 15 | addr_getword(string addr)Function: Read 16-bit unsigned decimal address | ||
| 16 | More script function are in the second section of [[“V-BOX Script Interface Manual”>>doc:V-BOX.V-Net.Manual.04 Lua Script.01 Lua Functions.WebHome]] | ||
| 17 | |||
| 18 | == **1.2 Arithmetic** == | ||
| 19 | |||
| 20 | (% style="text-align:center" %) | ||
| 21 | [[image:1624249623612-177.png||height="337" width="400" class="img-thumbnail"]] | ||
| 22 | |||
| 23 | == **1.3 Set 100 to D0~-~-D19** == | ||
| 24 | |||
| 25 | (% style="text-align:center" %) | ||
| 26 | [[image:1624249693457-742.png||height="135" width="400" class="img-thumbnail"]] | ||
| 27 | |||
| 28 | == **1.4 Short message** == | ||
| 29 | |||
| 30 | The following demo shows that when the alarm condition is reached: temp1 > 5 & temp2 >10 & temp3 < 20(lasts more than 5 seconds) , then send an "alarm trigger" sms. | ||
| 31 | |||
| 32 | When the alarm condition is released，then send an "alarm release" sms. Script is as below: | ||
| 33 | |||
| 34 | {{code language="lua"}} | ||
| 35 | function sms.main() | ||
| 36 | ------send condition------ | ||
| 37 | local temp1 = addr_getword("@Temperature1") | ||
| 38 | local temp2 = addr_getword("@Temperature2") | ||
| 39 | local temp3 = addr_getword("@Temperature3") | ||
| 40 | local timer = addr_getword("@Timer") | ||
| 41 | local tag = addr_getbit("@Tag") | ||
| 42 | ------lasting time------ | ||
| 43 | if temp1 > 5 and temp2 > 10 and temp3 < 20 then | ||
| 44 | timer = timer + 1 | ||
| 45 | addr_setword("@Timer",timer) | ||
| 46 | else | ||
| 47 | timer = 0 | ||
| 48 | addr_setword("@Timer",timer) | ||
| 49 | end | ||
| 50 | ------send sms & output Y0------ | ||
| 51 | if timer > 5 then | ||
| 52 | if tag == 0 then | ||
| 53 | send_sms_ira("19859254700","alarm trigger") | ||
| 54 | addr_setbit("@Tag",1) | ||
| 55 | end | ||
| 56 | elseif tag == 1 then | ||
| 57 | send_sms_ira("19859254700","alarm release") | ||
| 58 | addr_setbit("@Tag",0) | ||
| 59 | end | ||
| 60 | end | ||
| 61 | {{/code}} | ||
| 62 | |||
| 63 | == **1.5 Telegram notification** == | ||
| 64 | |||
| 65 | This example shows how to use the Bot API to send message into Telegram group or channel. When monitoring bit "@HDX" changes, it will trigger and send the message. Please replace with your own Token and chat id. | ||
| 66 | |||
| 67 | As for How to get the botToken and chatID, please check the followig videos: | ||
| 68 | |||
| 69 | [[https:~~/~~/www.youtube.com/watch?v=zh6yYlnjX7k>>https://www.youtube.com/watch?v=zh6yYlnjX7k]] | ||
| 70 | |||
| 71 | [[https:~~/~~/www.youtube.com/watch?v=Pj8mwuMZZvg>>https://www.youtube.com/watch?v=Pj8mwuMZZvg]] | ||
| 72 | |||
| 73 | {{code language="Lua"}} | ||
| 74 | local tempBit = 0 | ||
| 75 | local tempWord = 0 | ||
| 76 | |||
| 77 | local botToken = "5504549693:AAEy6a5G-sOF3CINONxMNABeYnoS4ABVlfg" | ||
| 78 | local chatID = "-641959124"--The chat id from Channel or Group | ||
| 79 | |||
| 80 | local https = require("https") | ||
| 81 | local json = require("json") | ||
| 82 | |||
| 83 | -- Send http.get request and return response result | ||
| 84 | function getHttpsUrl(url) | ||
| 85 | local body = {} | ||
| 86 | local bodyJson = json.encode(body) | ||
| 87 | local header = {} | ||
| 88 | header["content-type"] = "application/json" | ||
| 89 | local result_table, code, headers, status = https.request(url, bodyJson) | ||
| 90 | print("code:"..code) | ||
| 91 | if code~= 200 then | ||
| 92 | return | ||
| 93 | else | ||
| 94 | return body | ||
| 95 | end | ||
| 96 | end | ||
| 97 | |||
| 98 | function sendAlarm(telegramBotToken, message, telegramChatID) | ||
| 99 | local url = "https://api.telegram.org/bot"..telegramBotToken.."/sendMessage?text="..message.."&chat_id="..telegramChatID | ||
| 100 | --local url = 'http://v-box.net' | ||
| 101 | --local url = 'https://www.google.com/' | ||
| 102 | print("Get the link:"..url) | ||
| 103 | getHttpsUrl(url) | ||
| 104 | end | ||
| 105 | |||
| 106 | |||
| 107 | function AlarmNotificate.main() | ||
| 108 | local bitValue = addr_getbit("@HDX"); | ||
| 109 | local message = '' | ||
| 110 | print("b=="..bitValue) | ||
| 111 | if bitValue == 1 and bitValue ~= tempBit then | ||
| 112 | message = 'Alarm triggered, the monitoring point test value is '.. bitValue | ||
| 113 | sendAlarm(botToken, message, chatID) | ||
| 114 | print("Notification pushed of triggering alarm,"..bitValue) | ||
| 115 | elseif bitValue == 0 and bitValue ~= tempBit then | ||
| 116 | message = 'Alarm dismissed, the monitoring point test value is '.. bitValue | ||
| 117 | sendAlarm(botToken, message, chatID) | ||
| 118 | print("Notification pushed of dismissing alarm,"..bitValue) | ||
| 119 | end | ||
| 120 | tempBit = bitValue----Prevent monitoring values from continuous being sent to the platform | ||
| 121 | |||
| 122 | local wordValue = addr_getword("@HDW10") | ||
| 123 | print("w=="..wordValue) | ||
| 124 | --dosomething | ||
| 125 | if wordValue >= 100 and wordValue ~= tempWord and tempWord <= 100 then | ||
| 126 | message = 'Word alarm triggered, the word value is '.. wordValue | ||
| 127 | sendAlarm(botToken, message, chatID) | ||
| 128 | print("Notification pushed of triggering alarm,"..wordValue) | ||
| 129 | elseif wordValue < 100 and wordValue ~= tempWord and tempWord >= 100 then | ||
| 130 | message = 'Word alarm dismissed, the word value is '.. wordValue | ||
| 131 | sendAlarm(botToken, message, chatID) | ||
| 132 | print("Notification pushed of dismissing alarm,"..wordValue) | ||
| 133 | end | ||
| 134 | tempWord = wordValue----Prevent monitoring values from continuous being sent to the platform | ||
| 135 | end | ||
| 136 | {{/code}} | ||
| 137 | |||
| 138 | == **1.6 LINE Notify** == | ||
| 139 | |||
| 140 | This example shows how to use the LINE Notify to send message into LINE group. When monitoring bit "@test" changes, it will trigger and send the message. Please replace with your own Token. | ||
| 141 | |||
| 142 | {{code language="lua"}} | ||
| 143 | local tempBit = 0 | ||
| 144 | local tempWord = 0 | ||
| 145 | |||
| 146 | local LineToken = "08XCpubkOdwGdGgRTXF0x8umiyrALtoM0v6lBFUV6PC" | ||
| 147 | |||
| 148 | local https = require("https") | ||
| 149 | local json = require("json") | ||
| 150 | local ltn12 = require("ltn12") | ||
| 151 | |||
| 152 | -- Send http.get request and return response result | ||
| 153 | function getHttpsUrl(url,header,reqbody) | ||
| 154 | local body = {} | ||
| 155 | local bodyJson = json.encode(body) | ||
| 156 | local result_table, code, headers, status = https.request{ | ||
| 157 | method = "POST", | ||
| 158 | url = url, | ||
| 159 | source = ltn12.source.string(reqbody), | ||
| 160 | headers = header, | ||
| 161 | sink = ltn12.sink.table(body) | ||
| 162 | } | ||
| 163 | print("code:"..code) | ||
| 164 | if code~= 200 then | ||
| 165 | return | ||
| 166 | else | ||
| 167 | return body | ||
| 168 | end | ||
| 169 | end | ||
| 170 | |||
| 171 | function getMessageUrl(lineMessage) | ||
| 172 | local url = "https://notify-api.line.me/api/notify" | ||
| 173 | local reqMess = "message="..lineMessage | ||
| 174 | local headers = | ||
| 175 | { | ||
| 176 | ["Authorization"] = "Bearer "..LineToken, | ||
| 177 | ["Content-Type"] = "application/x-www-form-urlencoded", | ||
| 178 | ["Content-Length"] = #reqMess | ||
| 179 | } | ||
| 180 | |||
| 181 | print("Get the link:"..url) | ||
| 182 | getHttpsUrl(url, headers, reqMess) | ||
| 183 | end | ||
| 184 | |||
| 185 | |||
| 186 | function linenotify.main() | ||
| 187 | local bitValue = addr_getbit("@test"); | ||
| 188 | local message = '' | ||
| 189 | print("b=="..bitValue) | ||
| 190 | if bitValue == 1 and bitValue ~= tempBit then | ||
| 191 | message = 'Alarm V-Box triggered, the output is '.. bitValue | ||
| 192 | getMessageUrl(message) | ||
| 193 | print("Notification pushed of triggering alarm,"..bitValue) | ||
| 194 | elseif bitValue == 0 and bitValue ~= tempBit then | ||
| 195 | message = 'Alarm V-Box dismissed, the output is '.. bitValue | ||
| 196 | getMessageUrl(message) | ||
| 197 | print("Notification pushed of dismissing alarm,"..bitValue) | ||
| 198 | end | ||
| 199 | tempBit = bitValue----Prevent monitoring values from continuous being sent to the platform | ||
| 200 | |||
| 201 | local wordValue = addr_getword("@t2") | ||
| 202 | print("w=="..wordValue) | ||
| 203 | --dosomething | ||
| 204 | if wordValue >= 100 and wordValue ~= tempWord and tempWord <= 100 then | ||
| 205 | message = 'Alarm V-Box triggered, the temperature is '.. wordValue | ||
| 206 | getMessageUrl(message) | ||
| 207 | print("Notification pushed of triggering alarm,"..wordValue) | ||
| 208 | elseif wordValue < 100 and wordValue ~= tempWord and tempWord >= 100 then | ||
| 209 | message = 'Alarm V-Box dismissed, the temperature is '.. wordValue | ||
| 210 | getMessageUrl(message) | ||
| 211 | print("Notification pushed of dismissing alarm,"..wordValue) | ||
| 212 | end | ||
| 213 | tempWord = wordValue----Prevent monitoring values from continuous being sent to the platform | ||
| 214 | end | ||
| 215 | {{/code}} | ||
| 216 | |||
| 217 | == **1.7 Twilio WhatsApp Messaging** == | ||
| 218 | |||
| 219 | This example shows how to use the Twilio API to send WhatsApp message to private number. When monitoring bit "@testBit" changes, it will trigger and send the message. Please replace with your own SID, Token, twilioPhoneNumber and receiverPhoneNumber. | ||
| 220 | |||
| 221 | About how to register the Twilio API, please check the following video: | ||
| 222 | |||
| 223 | [[https:~~/~~/www.youtube.com/watch?v=Id4lKichauU>>https://www.youtube.com/watch?v=Id4lKichauU]] | ||
| 224 | |||
| 225 | {{code language="Lua"}} | ||
| 226 | local tempBit = 0 | ||
| 227 | local tempWord = 0 | ||
| 228 | |||
| 229 | local https = require("https") | ||
| 230 | local json = require("json") | ||
| 231 | local ltn12 = require("ltn12") | ||
| 232 | |||
| 233 | local SID = 'AC1703bd710ffa98006d2bcc0b********' | ||
| 234 | local Token = 'd3c11897623c39e538b20263ec19****' | ||
| 235 | |||
| 236 | local twilioPhoneNumber = '+14155238886' | ||
| 237 | local receiverPhoneNumber = '+8615880018277' | ||
| 238 | |||
| 239 | local b='ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/' | ||
| 240 | function encodingBase64(data) | ||
| 241 | return ((data:gsub('.', function(x) | ||
| 242 | local r,b='',x:byte() | ||
| 243 | for i=8,1,-1 do r=r..(b%2^i-b%2^(i-1)>0 and '1' or '0') end | ||
| 244 | return r; | ||
| 245 | end)..'0000'):gsub('%d%d%d?%d?%d?%d?', function(x) | ||
| 246 | if (#x < 6) then return '' end | ||
| 247 | local c=0 | ||
| 248 | for i=1,6 do c=c+(x:sub(i,i)=='1' and 2^(6-i) or 0) end | ||
| 249 | return b:sub(c+1,c+1) | ||
| 250 | end)..({ '', '==', '=' })[#data%3+1]) | ||
| 251 | end | ||
| 252 | |||
| 253 | function encodeUrl(str) | ||
| 254 | str = string.gsub(str, "([^%w%.%- ])", function(c) | ||
| 255 | return string.format("%%%02X", string.byte(c)) end) | ||
| 256 | return string.gsub(str, " ", "+") | ||
| 257 | end | ||
| 258 | |||
| 259 | |||
| 260 | |||
| 261 | |||
| 262 | function requestBodySplice(message, sender, receiver) | ||
| 263 | local reqBody = '' | ||
| 264 | local encodeMess = encodeUrl(message) | ||
| 265 | local encodeSend = encodeUrl(sender) | ||
| 266 | local encodeRece = encodeUrl(receiver) | ||
| 267 | --reqBody = "Body=Hello%20Wecon2&From=whatsapp%3A%2B14155238886&To=whatsapp%3A%2B8615880018277" | ||
| 268 | reqBody = string.format("Body=%s&From=whatsapp:%s&To=whatsapp:%s", encodeMess, encodeSend, encodeRece) | ||
| 269 | print(reqBody) | ||
| 270 | return reqBody | ||
| 271 | end | ||
| 272 | |||
| 273 | |||
| 274 | -- Send http.get request and return response result | ||
| 275 | function getHttpsUrl(url,header,reqbody) | ||
| 276 | local body = {} | ||
| 277 | local bodyJson = json.encode(body) | ||
| 278 | local result_table, code, headers, status = https.request{ | ||
| 279 | method = "POST", | ||
| 280 | url = url, | ||
| 281 | source = ltn12.source.string(reqbody), | ||
| 282 | headers = header, | ||
| 283 | sink = ltn12.sink.table(body) | ||
| 284 | } | ||
| 285 | print("code:"..code) | ||
| 286 | if code~= 200 then | ||
| 287 | return | ||
| 288 | else | ||
| 289 | return body | ||
| 290 | end | ||
| 291 | end | ||
| 292 | |||
| 293 | function getMessageUrl(whatsAppMessage) | ||
| 294 | local auth = SID..':'..Token | ||
| 295 | local url = "https://api.twilio.com/2010-04-01/Accounts/"..SID.."/Messages" | ||
| 296 | --local reqMess = "message="..twilioMessage | ||
| 297 | local reqMess = requestBodySplice(whatsAppMessage, twilioPhoneNumber, receiverPhoneNumber) | ||
| 298 | local headers = | ||
| 299 | { | ||
| 300 | ["Authorization"] = "Basic "..encodingBase64(auth), | ||
| 301 | ["Content-Type"] = "application/x-www-form-urlencoded", | ||
| 302 | ["Content-Length"] = #reqMess | ||
| 303 | } | ||
| 304 | |||
| 305 | print("Get the link:"..url) | ||
| 306 | getHttpsUrl(url, headers, reqMess) | ||
| 307 | end | ||
| 308 | |||
| 309 | |||
| 310 | |||
| 311 | function Twilio.main() | ||
| 312 | --dosomething | ||
| 313 | --local auth = SID..':'..Token | ||
| 314 | --print(requestBodySplice("HelloWorld", twilioPhoneNumber, receiverPhoneNumber)) | ||
| 315 | --print(encodingBase64(auth)) | ||
| 316 | local bitValue = addr_getbit("@testBit"); | ||
| 317 | local message = '' | ||
| 318 | print("b=="..bitValue) | ||
| 319 | if bitValue == 1 and bitValue ~= tempBit then | ||
| 320 | message = 'Alarm V-Box triggered, the output is '.. bitValue | ||
| 321 | getMessageUrl(message) | ||
| 322 | print("Notification pushed of triggering alarm,"..bitValue) | ||
| 323 | elseif bitValue == 0 and bitValue ~= tempBit then | ||
| 324 | message = 'Alarm V-Box dismissed, the output is '.. bitValue | ||
| 325 | getMessageUrl(message) | ||
| 326 | print("Notification pushed of dismissing alarm,"..bitValue) | ||
| 327 | end | ||
| 328 | tempBit = bitValue----Prevent monitoring values from continuous being sent to the platform | ||
| 329 | |||
| 330 | local wordValue = addr_getword("@testWord") | ||
| 331 | print("w=="..wordValue) | ||
| 332 | --dosomething | ||
| 333 | if wordValue >= 100 and wordValue ~= tempWord and tempWord <= 100 then | ||
| 334 | message = 'Alarm V-Box triggered, the temperature is '.. wordValue | ||
| 335 | getMessageUrl(message) | ||
| 336 | print("Notification pushed of triggering alarm,"..wordValue) | ||
| 337 | elseif wordValue < 100 and wordValue ~= tempWord and tempWord >= 100 then | ||
| 338 | message = 'Alarm V-Box dismissed, the temperature is '.. wordValue | ||
| 339 | getMessageUrl(message) | ||
| 340 | print("Notification pushed of dismissing alarm,"..wordValue) | ||
| 341 | end | ||
| 342 | tempWord = wordValue----Prevent monitoring values from continuous being sent to the platform | ||
| 343 | end | ||
| 344 | {{/code}} | ||
| 345 | |||
| 346 | == **1.8 How to parse value from HTTP response body** == | ||
| 347 | |||
| 348 | This example use [[https:~~/~~/www.weatherapi.com/>>https://www.weatherapi.com/]] as example, to show how to parse value from HTTP response body. When we input the city name into address "@HDW5050": | ||
| 349 | |||
| 350 | (% style="text-align:center" %) | ||
| 351 | [[image:InputHTTPparameter.png]] | ||
| 352 | |||
| 353 | Then the response body would be like as following: | ||
| 354 | |||
| 355 | {{code language="json"}} | ||
| 356 | { | ||
| 357 | "location": { | ||
| 358 | "name": "Madrid", | ||
| 359 | "region": "Madrid", | ||
| 360 | "country": "Spain", | ||
| 361 | "lat": 40.4, | ||
| 362 | "lon": -3.68, | ||
| 363 | "tz_id": "Europe/Madrid", | ||
| 364 | "localtime_epoch": 1669022636, | ||
| 365 | "localtime": "2022-11-21 10:23" | ||
| 366 | }, | ||
| 367 | "current": { | ||
| 368 | "last_updated_epoch": 1669022100, | ||
| 369 | "last_updated": "2022-11-21 10:15", | ||
| 370 | "temp_c": 13.0, | ||
| 371 | "temp_f": 55.4, | ||
| 372 | "is_day": 1, | ||
| 373 | "condition": { | ||
| 374 | "text": "Partly cloudy", | ||
| 375 | "icon": "//cdn.weatherapi.com/weather/64x64/day/116.png", | ||
| 376 | "code": 1003 | ||
| 377 | }, | ||
| 378 | "wind_mph": 11.9, | ||
| 379 | "wind_kph": 19.1, | ||
| 380 | "wind_degree": 210, | ||
| 381 | "wind_dir": "SSW", | ||
| 382 | "pressure_mb": 1015.0, | ||
| 383 | "pressure_in": 29.97, | ||
| 384 | "precip_mm": 0.0, | ||
| 385 | "precip_in": 0.0, | ||
| 386 | "humidity": 88, | ||
| 387 | "cloud": 75, | ||
| 388 | "feelslike_c": 10.8, | ||
| 389 | "feelslike_f": 51.4, | ||
| 390 | "vis_km": 10.0, | ||
| 391 | "vis_miles": 6.0, | ||
| 392 | "uv": 3.0, | ||
| 393 | "gust_mph": 22.1, | ||
| 394 | "gust_kph": 35.6 | ||
| 395 | } | ||
| 396 | } | ||
| 397 | {{/code}} | ||
| 398 | |||
| 399 | (% class="wikigeneratedid" %) | ||
| 400 | So we decode json into lua object to assign the value into addresses HDW6060(temperature), HDW7070(humidity), the code example like follows: | ||
| 401 | |||
| 402 | {{code language="lua"}} | ||
| 403 | local APIkey = '70faaecf926b4341b1974006221711' | ||
| 404 | |||
| 405 | |||
| 406 | local http = require("socket.http") | ||
| 407 | local json = require("json") | ||
| 408 | |||
| 409 | -- Send http.get request and return response result | ||
| 410 | function getHttpsUrl(url) | ||
| 411 | local result_table, code, headers, status = http.request(url) | ||
| 412 | print("code:"..code) | ||
| 413 | if code~= 200 then | ||
| 414 | return | ||
| 415 | else | ||
| 416 | return result_table | ||
| 417 | end | ||
| 418 | end | ||
| 419 | |||
| 420 | function sendAPI(key, city) | ||
| 421 | local url = "http://api.weatherapi.com/v1/current.json?key="..key.."&q="..city.."&aqi=no" | ||
| 422 | --local url = 'http://v-box.net' | ||
| 423 | --local url = 'https://www.google.com/' | ||
| 424 | --http://api.weatherapi.com/v1/current.json?key=70faaecf926b4341b1974006221711&q=Barcelona&aqi=no | ||
| 425 | print("Get the link:"..url) | ||
| 426 | local body = getHttpsUrl(url) | ||
| 427 | --print(body) | ||
| 428 | local jsonBody = json.decode(body) | ||
| 429 | --print(jsonBody["current"]["temp_c"]) | ||
| 430 | --print(type(jsonBody["current"]["temp_c"])) | ||
| 431 | --print(type(jsonBody["current"]["humidity"])) | ||
| 432 | addr_setfloat("@HDW6060", jsonBody["current"]["temp_c"]) | ||
| 433 | addr_setword("@HDW7070", jsonBody["current"]["humidity"]) | ||
| 434 | end | ||
| 435 | |||
| 436 | |||
| 437 | function Weather.main() | ||
| 438 | local cityName = addr_getstring("@HDW5050",6) | ||
| 439 | print("cityName: "..cityName) | ||
| 440 | sendAPI(APIkey, cityName) | ||
| 441 | end | ||
| 442 | {{/code}} | ||
| 443 | |||
| 444 | == **1.9 High-Low Byte Switch** == | ||
| 445 | |||
| 446 | The following example is converting the floating number from order 1234 to order 3412, and formating output the number with 2 decimal point. About which high-low word order corresponding to which value, please refer to the [[Address Operation Table>>doc:V-BOX.V-Net.Manual.04 Lua Script.01 Lua Functions.WebHome||anchor="H2Addressoperation"]]. | ||
| 447 | |||
| 448 | {{code language="lua"}} | ||
| 449 | function highLowByteSwitch(floatNumber) | ||
| 450 | addr_setfloat("@W_0#HDW23036",floatNumber,0,2) | ||
| 451 | local newFloat = addr_getfloat("@W_0#HDW23036") | ||
| 452 | local formattedFloat = string.format("%.2f",newFloat) | ||
| 453 | print("The formatted float value is the : "..formattedFloat) | ||
| 454 | return formattedFloat | ||
| 455 | end | ||
| 456 | {{/code}} | ||
| 457 | |||
| 458 | == **1.10 Read 64bits Unsigned Value** == | ||
| 459 | |||
| 460 | In our built-in function library doesn't have the function for reading 64-bit unsigned format value, so the following function is for solve this. But if the number is greater 2^53, the precision will be lost. So the final result will be a little bit different from the original value. | ||
| 461 | |||
| 462 | {{code language="lua"}} | ||
| 463 | function addr_getquatra(address) | ||
| 464 | local highAddress = addr_newnoaddr(address,2) | ||
| 465 | local low32 = addr_getdword(address) | ||
| 466 | local high32 = addr_getdword(highAddress) | ||
| 467 | --print("the low number is "..low32) | ||
| 468 | --print("the high number is "..high32) | ||
| 469 | local formatVal = string.format("%64.0f",2^32*high32+low32) | ||
| 470 | print("the format value is ".. formatVal) | ||
| 471 | return formatVal | ||
| 472 | end | ||
| 473 | {{/code}} | ||
| 474 | |||
| 475 | = **2 V-Box connect with third part server** = | ||
| 476 | |||
| 477 | V-Box have two mode.One is for V-Net,User need to use WECON server to store data.We call this V-NET platform. | ||
| 478 | |||
| 479 | (% class="mark" %)1.Europe server:eu.v-box.net | ||
| 480 | |||
| 481 | (% class="mark" %)2.Asean server:asean.v-box.net | ||
| 482 | |||
| 483 | Second is for OpenCloud mode.It means V-Box data will transfer to third part server and do not want to store data to WECON server.We call OpenCloud paltform | ||
| 484 | |||
| 485 | OpenCloud platform is used in configuring the script.Then V-Box can connect with third part server. | ||
| 486 | |||
| 487 | Both mode can support script to connect with third part server.the difference: | ||
| 488 | |||
| 489 | (% class="mark" %)1.If you want to store in WECON server ,please use V-NET. | ||
| 490 | |||
| 491 | (% class="mark" %)2.If your server requires SSL certificate to log in,please use OpenCloud.Because only OpenCloud platform can support to upload certificate | ||
| 492 | |||
| 493 | {{info}} | ||
| 494 | **✎Note: **Before program the script of MQTT, please make sure the server(MQTT broker) can be connected through MQTT Client tool. | ||
| 495 | {{/info}} | ||
| 496 | |||
| 497 | (% class="wikigeneratedid" %) | ||
| 498 | Tool link: **[[MQTT.fx>>http://mqttfx.jensd.de/index.php/download]]** | ||
| 499 | |||
| 500 | == **2.1 V-Box connect with test server(General Example)** == | ||
| 501 | |||
| 502 | The following example is trying to publish to the topic "testtopic/test/no1/7890", and subscribe the topic "testtopic/test/no1/123456". | ||
| 503 | |||
| 504 | And the JSON message is like follows: | ||
| 505 | |||
| 506 | {{code language="JSON"}} | ||
| 507 | { | ||
| 508 | "timestamp": 1631152760, | ||
| 509 | "messageId": 1, | ||
| 510 | "event": "test_data", | ||
| 511 | "mfrs": "HMI/box", | ||
| 512 | "data": | ||
| 513 | { | ||
| 514 | "id" : 1436217747670454274, | ||
| 515 | "waterlevel" : 48, | ||
| 516 | "temperture" : 23 | ||
| 517 | } | ||
| 518 | } | ||
| 519 | {{/code}} | ||
| 520 | |||
| 521 | {{code language="lua"}} | ||
| 522 | --MQTT configuration table | ||
| 523 | local MQTT_CFG={} | ||
| 524 | --if there is no need the username and password, please put them as "" | ||
| 525 | MQTT_CFG.username = "weconsupport" | ||
| 526 | MQTT_CFG.password = "123456" | ||
| 527 | MQTT_CFG.netway = 0 | ||
| 528 | MQTT_CFG.keepalive = 60 | ||
| 529 | MQTT_CFG.cleansession = 1 | ||
| 530 | --TCP URL | ||
| 531 | MQTT_URL = "tcp://mq.tongxinmao.com:1883" | ||
| 532 | --Client ID | ||
| 533 | MQTT_CLIENT_ID = "V-BOXH-AG" | ||
| 534 | |||
| 535 | --Generate UUID | ||
| 536 | function uuid() | ||
| 537 | local seed = {'e','1','2','3','4','5','6','7','8','9','a','b','c','d','e','f'} | ||
| 538 | local tb = {} | ||
| 539 | for i=1, 32 do | ||
| 540 | table.insert(tb, seed[math.random(1,16)]) | ||
| 541 | end | ||
| 542 | local sid=table.concat(tb) | ||
| 543 | return string.format('%s', | ||
| 544 | string.sub(sid,1,32) | ||
| 545 | ) | ||
| 546 | end | ||
| 547 | |||
| 548 | |||
| 549 | --Topic name to subscribed | ||
| 550 | local SUBSCRIBE_TOPIC = 'testtopic/test/no1/123456' | ||
| 551 | |||
| 552 | --Topic name to be published | ||
| 553 | local PUBLISH_TOPIC = 'testtopic/test/no1/7890' | ||
| 554 | |||
| 555 | |||
| 556 | --real time | ||
| 557 | local LAST_TIME = 0 | ||
| 558 | |||
| 559 | |||
| 560 | --initialize mqtt | ||
| 561 | function mqtt_init() | ||
| 562 | print(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENT_ID)) | ||
| 563 | if g_mq then | ||
| 564 | mqtt.close(g_mq) --Close mqtt object | ||
| 565 | end | ||
| 566 | g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENT_ID) -- create mqtt object,and declare it as a global variable | ||
| 567 | if g_mq then | ||
| 568 | g_mq:on("message", mqtt_msg_callback) -- Register a callback for receiving messages | ||
| 569 | g_mq:on("offline", mqtt_msg_offline) -- Register a callback for offline | ||
| 570 | print("mqtt init success") | ||
| 571 | else | ||
| 572 | print("mqtt init failed:", err) | ||
| 573 | end | ||
| 574 | end | ||
| 575 | |||
| 576 | -- connect to mqtt | ||
| 577 | function mqtt_connect() | ||
| 578 | print("mqtt connecting...") | ||
| 579 | local stat, err = g_mq:connect(MQTT_CFG) | ||
| 580 | if stat == nil then | ||
| 581 | print("mqtt connect failed:", err) | ||
| 582 | return | ||
| 583 | else | ||
| 584 | print("mqtt connected") | ||
| 585 | end | ||
| 586 | g_mq:subscribe(SUBSCRIBE_TOPIC, 0) | ||
| 587 | end | ||
| 588 | |||
| 589 | --Offline callback function | ||
| 590 | function mqtt_msg_offline(cause) | ||
| 591 | print("mqtt offline, cause:", cause) | ||
| 592 | end | ||
| 593 | |||
| 594 | -- Received message callback function | ||
| 595 | function mqtt_msg_callback(topic, msg) | ||
| 596 | print("topic:", topic) | ||
| 597 | print("msg:", msg) | ||
| 598 | local objMsg = json.decode(msg) | ||
| 599 | local water = objMsg.data.waterlevel | ||
| 600 | local temp = objMsg.data.temperature | ||
| 601 | addr_setword("@HDW20",water) | ||
| 602 | addr_setword("@HDW10",temp) | ||
| 603 | end | ||
| 604 | |||
| 605 | --Send data (data upload to platform and encapsulate it with custom functions) | ||
| 606 | function send_data() | ||
| 607 | local pub_data = { | ||
| 608 | timestamp = os.time(), | ||
| 609 | messageId = 1, | ||
| 610 | event = 'test_data', | ||
| 611 | mfrs = 'V-Box', | ||
| 612 | data = { | ||
| 613 | id = uuid(), | ||
| 614 | waterlevel = addr_getword("@HDW10"), | ||
| 615 | temperature = addr_getword("@HDW20") | ||
| 616 | } | ||
| 617 | } | ||
| 618 | return g_mq:publish(PUBLISH_TOPIC, json.encode(pub_data), 0, 0) | ||
| 619 | end | ||
| 620 | |||
| 621 | |||
| 622 | --main function fixed timed execution | ||
| 623 | function MQTT.main() | ||
| 624 | --dosomething | ||
| 625 | print(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " main start") | ||
| 626 | --determine the mqtt object whether exist | ||
| 627 | if g_mq then | ||
| 628 | --determine the mqtt object whether has been connected or not | ||
| 629 | if g_mq:isconnected() then | ||
| 630 | send_data() | ||
| 631 | else | ||
| 632 | --if exceed 5 sec not connect, reconnect once | ||
| 633 | if os.time() - LAST_TIME > 5 then | ||
| 634 | LAST_TIME = os.time() | ||
| 635 | --reinitial the mqtt object | ||
| 636 | mqtt_init() | ||
| 637 | --connect to mqtt or reconnect | ||
| 638 | mqtt_connect() | ||
| 639 | end | ||
| 640 | end | ||
| 641 | else | ||
| 642 | --mqtt object does not exist so create new one | ||
| 643 | mqtt_init() | ||
| 644 | end | ||
| 645 | print(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " main end") | ||
| 646 | end | ||
| 647 | {{/code}} | ||
| 648 | |||
| 649 | == **2.2 V-Box connect with customer server:grouprobotinfo.com** == | ||
| 650 | |||
| 651 | This demo does not use SSL certification. Script is as below | ||
| 652 | |||
| 653 | Demo1: | ||
| 654 | |||
| 655 | {{code language="lua"}} | ||
| 656 | -- Meta class | ||
| 657 | --main | ||
| 658 | function mq.main() | ||
| 659 | if not mq.m then | ||
| 660 | local err = "" | ||
| 661 | |||
| 662 | mq.m, err = mqtt.create("tcp://grouprobotinfo.com:1883", "ClienID") -- create connection | ||
| 663 | if mq.m then | ||
| 664 | mq.config = { | ||
| 665 | username = "",-- ID | ||
| 666 | password = "",-- password | ||
| 667 | netway = 1, -- Ethernet connection, WIFI=1 | ||
| 668 | -- keepalive = 100, -- Optional, set the connection heartbeat interval for 100 seconds. | ||
| 669 | -- cleansession = 0, -- Optional, keep session | ||
| 670 | } | ||
| 671 | mq.m:on("message", function(topic, msg) -- Register for receiving message callbacks | ||
| 672 | local str = string.format("%s:%s", topic, msg) | ||
| 673 | -- print("mqtt msg:", str) -- Print out the received topics and content | ||
| 674 | end) | ||
| 675 | mq.m:on("offline", function (cause) -- Register for lost connection callbacks | ||
| 676 | -- addr_setstring("@xxx", "cause"..(cause or " got nil")) | ||
| 677 | end) | ||
| 678 | mq.m:on("arrived", function() -- Registration for sending messages to callbacks | ||
| 679 | print("msg arrived") | ||
| 680 | end) | ||
| 681 | else | ||
| 682 | print("mqtt create failed:", err) -- Create object failed | ||
| 683 | end | ||
| 684 | else | ||
| 685 | if mq.m:isconnected() then -- If online, post a message | ||
| 686 | local phaseStatus ="unknow" | ||
| 687 | if addr_getbit("@Standby")== 1 then | ||
| 688 | phaseStatus = "Standby" | ||
| 689 | elseif addr_getbit("@Pre-Freeze")==1 then | ||
| 690 | phaseStatus= "Pre-Freeze" | ||
| 691 | elseif addr_getbit("@Prepare")==1 then | ||
| 692 | phaseStatus ="Prepare" | ||
| 693 | elseif addr_getbit("@Primary Dry")==1 then | ||
| 694 | phaseStatus = "Primary dry" | ||
| 695 | elseif addr_getbit("@Secondary Dry")==1 then | ||
| 696 | phaseStatus = "Secondary Dry" | ||
| 697 | end | ||
| 698 | --print(addr_getbit("@Primary Dry")) | ||
| 699 | ------------------------------------------------------------------------------------------------------------------------- | ||
| 700 | local activating ="unknow" | ||
| 701 | if addr_getbit("@Compressor")==1 then | ||
| 702 | activating = ",".."Compressor" | ||
| 703 | end | ||
| 704 | if addr_getbit("@Silicone Pump")==1 then | ||
| 705 | activating = activating..",".."Silicone Pump" | ||
| 706 | end | ||
| 707 | if addr_getbit("@Vacuum Pump")==1 then | ||
| 708 | activating = activating..",".."Vacuum Pump" | ||
| 709 | end | ||
| 710 | if addr_getbit("@Root Pump")==1 then | ||
| 711 | activating = activating..",".."Root Pump" | ||
| 712 | end | ||
| 713 | if addr_getbit("@Heater")==1 then | ||
| 714 | activating = activating..",".."Heater" | ||
| 715 | end | ||
| 716 | if addr_getbit("@Valve Silicone")==1 then | ||
| 717 | activating = activating..",".."Valve Silicone" | ||
| 718 | end | ||
| 719 | if addr_getbit("@Valve Ice Condenser")==1 then | ||
| 720 | activating = activating..",".."Valve Ice Condenser" | ||
| 721 | end | ||
| 722 | if addr_getbit("@Valve Vacuum Pump")==1 then | ||
| 723 | activating = activating..",".."Valve Vacuum Pump" | ||
| 724 | end | ||
| 725 | local pr_activating =string.sub(activating,2) | ||
| 726 | -- print(pr_activating) | ||
| 727 | local status_text ="unknow" | ||
| 728 | if addr_getbit("@Status Run")==1 then | ||
| 729 | status_text = "RUNNING" | ||
| 730 | else | ||
| 731 | status_text = "STOP" | ||
| 732 | end | ||
| 733 | ------------------------------------------------------------------------------------------------------------------------- | ||
| 734 | local js = {type="status", | ||
| 735 | mc_name ="FD300", | ||
| 736 | status=status_text, | ||
| 737 | elapsed_time={ | ||
| 738 | hour=addr_getword("@Elapsed Time (Hour)"), | ||
| 739 | min=addr_getword("@Elapsed Time (Minute)"), | ||
| 740 | sec=addr_getword("@Elapsed Time (Second)") | ||
| 741 | }, | ||
| 742 | phase = phaseStatus, | ||
| 743 | step = addr_getword("@Step"), | ||
| 744 | activating_output = pr_activating, | ||
| 745 | sv=addr_getshort("@SV Silicone")/10, | ||
| 746 | pv=addr_getshort("@PV Silicone")/10, | ||
| 747 | product1=addr_getshort("@Product 1")/10, | ||
| 748 | |||
| 749 | product2=addr_getshort("@Product 2")/10, | ||
| 750 | product3=addr_getshort("@Product 3")/10, | ||
| 751 | product4=addr_getshort("@Product 4")/10, | ||
| 752 | ice1=addr_getshort("@Ice condenser 1")/10, | ||
| 753 | ice2=addr_getshort("@Ice condenser 2")/10, | ||
| 754 | vacuum=addr_getfloat("@Vacuum") | ||
| 755 | } | ||
| 756 | local jsAlarm = { HPC = addr_getbit("@B_25395#W0.00"), | ||
| 757 | ODPC = addr_getbit("@B_25395#W0.01"), | ||
| 758 | MTPC=addr_getbit("@B_25395#W0.02"), | ||
| 759 | HTT = addr_getbit("@B_25395#W1.03"), | ||
| 760 | CPC = addr_getbit("@B_25395#W0.08"), | ||
| 761 | CPSP =addr_getbit("@B_25395#W1.00"), | ||
| 762 | CPVP =addr_getbit("@B_25395#W0.10"), | ||
| 763 | CPRP =addr_getbit("@B_25395#W0.11"), | ||
| 764 | HP =addr_getbit("@B_25395#W1.01"), | ||
| 765 | PP= addr_getbit("@B_25395#W1.02"), | ||
| 766 | PO=addr_getbit("@B_25395#W0.07"), | ||
| 767 | FSE=addr_getbit("@B_25395#W2.04"), | ||
| 768 | AVVSVV=addr_getbit("@B_25395#W1.12"), | ||
| 769 | ICHT=addr_getbit("@B_25395#W3.06") | ||
| 770 | } | ||
| 771 | -- ("@B_25395#CIO1.02") | ||
| 772 | mq.m:publish("mqtt-v-box-epsilon-fd300", json.encode(js) , 0, 0) | ||
| 773 | mq.m:publish("mqtt-v-box-epsilon-alarm-fd300", json.encode(jsAlarm) , 0, 0) | ||
| 774 | else | ||
| 775 | local stat, err = mq.m:connect(mq.config) -- connection | ||
| 776 | if stat == nil then --Determine whether to connect | ||
| 777 | print("mqtt connect failed:", err) | ||
| 778 | return -- Connection failed, return directly | ||
| 779 | end | ||
| 780 | mq.m:subscribe("mqtt-v-box-epsilon", 0)-- Subscribe to topics | ||
| 781 | |||
| 782 | end | ||
| 783 | -- mq.m:unsubscribe("stc/test") | ||
| 784 | -- mq.m:disconnect() -- close matt | ||
| 785 | -- mq.m:close() -- close clase | ||
| 786 | end | ||
| 787 | end | ||
| 788 | {{/code}} | ||
| 789 | |||
| 790 | == **2.3 V-Box connect with Azure platform** == | ||
| 791 | |||
| 792 | In this demo,V-Box connects with Azure by SSL certification. | ||
| 793 | |||
| 794 | Video link: [[https:~~/~~/youtu.be/cdI6rIQcpMY?list=PL_Bpnb2RgaksCic9HCcVAZhU9sYwCRKzW>>https://youtu.be/cdI6rIQcpMY?list=PL_Bpnb2RgaksCic9HCcVAZhU9sYwCRKzW]] | ||
| 795 | |||
| 796 | Tool Download link: [[https:~~/~~/wecon-disk.oss-ap-southeast-1.aliyuncs.com/Download/WIKI/V-BOX/Demo/Azure/Azure%20tool.zip>>https://wecon-disk.oss-ap-southeast-1.aliyuncs.com/Download/WIKI/V-BOX/Demo/Azure/Azure%20tool.zip]] | ||
| 797 | |||
| 798 | Script is as below | ||
| 799 | |||
| 800 | (% class="box infomessage" %) | ||
| 801 | ((( | ||
| 802 | ~-~-https:~/~/support.huaweicloud.com/qs-IoT/iot_05_0005.html mqtt.fx monitor to connect azure iot | ||
| 803 | sprint = print | ||
| 804 | |||
| 805 | ~-~-Get custom configuration parameters (vbox custom information) | ||
| 806 | ~-~-local CUSTOM = bns_get_config("bind") | ||
| 807 | ~-~-local DS_ID = CUSTOM.DSID or "60a71ccbbbe12002c08f3a1a_WECON" | ||
| 808 | |||
| 809 | |||
| 810 | ~-~-Cloud mode interface to obtain the MQTT information configured by the cloud platform: (5 returns, namely the server address, client ID, connection table, last word table, certificate table) | ||
| 811 | local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg() | ||
| 812 | |||
| 813 | ~-~-MQTT_CFG.username = '60a71ccbbbe12002c08f3a1a_WECON' | ||
| 814 | ~-~-MQTT_CFG.password='wecon123' | ||
| 815 | ~-~-MQTT_CLIENTID = '60a71ccbbbe12002c08f3a1a_WECON_0_0_2021052110usernxame:60a71ccbbbe12002c08f3a1a_WECONpassword:a0a951581855aa8e0262129da6cf1b43f2c0ecfac4fa56117fc5a20c90be169a' | ||
| 816 | |||
| 817 | ~-~-publish to topics | ||
| 818 | local pub_RE_TOPIC = string.format('devices/wecon_02/messages/events/') | ||
| 819 | ~-~-Subscribe topics | ||
| 820 | local Subscribe_RE_TOPIC1 = string.format('devices/wecon_02/messages/devicebound/#') | ||
| 821 | |||
| 822 | ~-~-variable | ||
| 823 | local last_time = 0 | ||
| 824 | |||
| 825 | |||
| 826 | ~-~-Timing main function | ||
| 827 | function Azure.main() | ||
| 828 | |||
| 829 | sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " Azureiot.main start") | ||
| 830 | if g_mq then | ||
| 831 | if g_mq:isconnected() then | ||
| 832 | send_Data() | ||
| 833 | else | ||
| 834 | if os.time() - last_time > 20 then | ||
| 835 | last_time = os.time() | ||
| 836 | mymqtt_connect() | ||
| 837 | end | ||
| 838 | end | ||
| 839 | else | ||
| 840 | mymqtt_init() | ||
| 841 | end | ||
| 842 | sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " Azureiot.main end") | ||
| 843 | end | ||
| 844 | |||
| 845 | ~-~- Initialize MQTT | ||
| 846 | function mymqtt_init() | ||
| 847 | sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID)) | ||
| 848 | g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable | ||
| 849 | if g_mq then | ||
| 850 | g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks | ||
| 851 | sprint("mqtt init success") | ||
| 852 | else | ||
| 853 | sprint("mqtt init failed:", err) | ||
| 854 | end | ||
| 855 | end | ||
| 856 | |||
| 857 | ~-~- Connect to MQTT server | ||
| 858 | function mymqtt_connect() | ||
| 859 | sprint("mqtt connecting...") | ||
| 860 | local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART) | ||
| 861 | if stat == nil then | ||
| 862 | sprint("mqtt connect failed:", err) | ||
| 863 | return | ||
| 864 | else | ||
| 865 | sprint("mqtt connected") | ||
| 866 | end | ||
| 867 | g_mq:subscribe(Subscribe_RE_TOPIC1, 0) | ||
| 868 | end | ||
| 869 | |||
| 870 | ~-~- Receive MQTT message callback function | ||
| 871 | function mymqtt_msg_callback(topic, msg) | ||
| 872 | print("topic:",topic) | ||
| 873 | print("revdata:",msg) | ||
| 874 | ~-~- local revData = json.decode(msg) | ||
| 875 | ~-~- if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud | ||
| 876 | ~-~- if string.match(topic,Subscribe_RE_TOPIC1) then | ||
| 877 | ~-~- print("topi11:",topic) | ||
| 878 | setValue(revData) | ||
| 879 | ~-~- end | ||
| 880 | end | ||
| 881 | |||
| 882 | ~-~-Process the received data | ||
| 883 | ~-~-function setValue(revData) | ||
| 884 | ~-~- if revData ~~=nil then | ||
| 885 | ~-~- for i,v in pairs(revData) do | ||
| 886 | ~-~- print("Data received：",i,v) | ||
| 887 | ~-~- end | ||
| 888 | ~-~- end | ||
| 889 | ~-~-end | ||
| 890 | |||
| 891 | ~-~-Get real-time data | ||
| 892 | function getData() | ||
| 893 | local jdata = {} | ||
| 894 | local addr = bns_get_alldata() | ||
| 895 | print(json.encode(addr)) | ||
| 896 | for i,v in pairs(addr) do | ||
| 897 | if v[2] == 1 then | ||
| 898 | jdata[v[3]] = v[4] | ||
| 899 | end | ||
| 900 | end | ||
| 901 | return jdata | ||
| 902 | end | ||
| 903 | |||
| 904 | |||
| 905 | ~-~-send data | ||
| 906 | function send_Data() | ||
| 907 | local pub_data = {100 | ||
| 908 | ~-~- services=~{~{ | ||
| 909 | \\ ~-~-serviceId ='Temperature', | ||
| 910 | ~-~- properties={ | ||
| 911 | ~-~- value = 55 | ||
| 912 | ~-~- }, | ||
| 913 | ~-~- }} | ||
| 914 | } | ||
| 915 | sprint(json.encode(pub_data)) | ||
| 916 | print("..........",pub_RE_TOPIC) | ||
| 917 | return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0) | ||
| 918 | end | ||
| 919 | ))) | ||
| 920 | |||
| 921 | == **2.4 How to configure the Huawei platform?（✎Note: Huawei IOT DA function is only in China area.If you want this function,you need to use chinese mobile to register）** == | ||
| 922 | |||
| 923 | 1.Register a account: [[https:~~/~~/www.huaweicloud.com/intl/en-us/s/JUlPVERNJQ>>https://www.huaweicloud.com/intl/en-us/s/JUlPVERNJQ]] | ||
| 924 | |||
| 925 | 2.log in the Huawei IOTDA | ||
| 926 | |||
| 927 | [[https:~~/~~/console.huaweicloud.com/iotdm/?region=cn-north-4&locale=en-us#/dm-portal/home>>https://console.huaweicloud.com/iotdm/?region=cn-north-4&locale=en-us#/dm-portal/home]] | ||
| 928 | |||
| 929 | 3.Create product | ||
| 930 | |||
| 931 | (% style="text-align:center" %) | ||
| 932 | [[image:1624433478954-859.png||height="497" width="1100" class="img-thumbnail"]] | ||
| 933 | |||
| 934 | 4.Product name,manufacturer,device type and industry,set according to your own needs. | ||
| 935 | |||
| 936 | Protocol: MQTT | ||
| 937 | |||
| 938 | Data Type: JSON | ||
| 939 | |||
| 940 | After finishing configuration,please click "OK" | ||
| 941 | |||
| 942 | (% style="text-align:center" %) | ||
| 943 | [[image:1624433531968-337.png||height="568" width="700" class="img-thumbnail"]] | ||
| 944 | |||
| 945 | 5.Device | ||
| 946 | |||
| 947 | After product register,continue to configure "individual register".Click "Device"~-~->"individual register" | ||
| 948 | |||
| 949 | (% style="text-align:center" %) | ||
| 950 | [[image:1624434757597-117.png||class="img-thumbnail"]] | ||
| 951 | |||
| 952 | **Notes for registering device:** | ||
| 953 | |||
| 954 | Product: Previous product registration. | ||
| 955 | |||
| 956 | Node ID, Device Name: set according to your own needs. | ||
| 957 | |||
| 958 | Secret: need to be configured, will be used when connecting later | ||
| 959 | |||
| 960 | After configuration, click OK to generate a device ID and password, which will be used for device access later. | ||
| 961 | |||
| 962 | (% style="text-align:center" %) | ||
| 963 | [[image:1624436421499-613.png||height="499" width="700" class="img-thumbnail"]] | ||
| 964 | |||
| 965 | (% style="text-align:center" %) | ||
| 966 | [[image:1624437798012-126.png||height="366" width="500" class="img-thumbnail"]] | ||
| 967 | |||
| 968 | 6. Connection authentication (use MQTT.fx tool to access the IoT platform) | ||
| 969 | |||
| 970 | (1)Open mqttClientIdGenerator tool Java(TM) Platform SE binary | ||
| 971 | |||
| 972 | **[[Download>>https://wecon-disk.oss-ap-southeast-1.aliyuncs.com/Download/WIKI/V-BOX/Demo/Huawei/mqttClientIdGenerator-19.2.0.zip]]** | ||
| 973 | |||
| 974 | (% style="text-align:center" %) | ||
| 975 | [[image:1624437573798-815.png||height="351" width="700" class="img-thumbnail"]] | ||
| 976 | |||
| 977 | (2)Fill in the device ID and secret (deviceid and secret generated when registering the device) to generate connection message | ||
| 978 | |||
| 979 | Client ID, user name, password | ||
| 980 | |||
| 981 | (% style="text-align:center" %) | ||
| 982 | [[image:1624437756866-251.png||height="405" width="700" class="img-thumbnail"]] | ||
| 983 | |||
| 984 | (3) Download certificate file"North-Beijing4" | ||
| 985 | |||
| 986 | [[https:~~/~~/support.huaweicloud.com/en-us/devg-iothub/iot_02_1004.html>>https://support.huaweicloud.com/en-us/devg-iothub/iot_02_1004.html]] | ||
| 987 | |||
| 988 | (% style="text-align:center" %) | ||
| 989 | [[image:1624438225398-363.png||height="403" width="800" class="img-thumbnail"]] | ||
| 990 | |||
| 991 | (% style="text-align:center" %) | ||
| 992 | [[image:1624438260025-610.png||height="408" width="700" class="img-thumbnail"]] | ||
| 993 | |||
| 994 | 7.Run MQTTfx tool to connect with Huawei | ||
| 995 | |||
| 996 | Download link: [[http:~~/~~/mqttfx.jensd.de/index.php/download>>url:http://mqttfx.jensd.de/index.php/download]] | ||
| 997 | |||
| 998 | (1)Click on the setting ICON | ||
| 999 | |||
| 1000 | (% style="text-align:center" %) | ||
| 1001 | [[image:1624438821280-974.png||height="198" width="500" class="img-thumbnail"]] | ||
| 1002 | |||
| 1003 | (2)Fill in IIOT MQTT device access address, and configure authentication parameters. | ||
| 1004 | First: It is the server and port connected to Huawei IOT, which can be viewed through the overview of the interface. | ||
| 1005 | |||
| 1006 | (% style="text-align:center" %) | ||
| 1007 | [[image:1624439086268-985.png||class="img-thumbnail"]] | ||
| 1008 | |||
| 1009 | Domain name:iot-mqtts.cn-north-4.myhuaweicloud.com | ||
| 1010 | |||
| 1011 | Port: 8883 | ||
| 1012 | |||
| 1013 | Client ID: check step 6 | ||
| 1014 | |||
| 1015 | (% style="text-align:center" %) | ||
| 1016 | [[image:1624439672168-492.png||height="458" width="600" class="img-thumbnail"]] | ||
| 1017 | |||
| 1018 | (3)Upload SSL certificate file,check step 6 | ||
| 1019 | |||
| 1020 | Select folder java~-~->DigiCertGlobalRootCA.crt.pem and click OK or apply button | ||
| 1021 | |||
| 1022 | (% style="text-align:center" %) | ||
| 1023 | [[image:1624439912938-659.png||height="458" width="600" class="img-thumbnail"]] | ||
| 1024 | |||
| 1025 | (4)Connect and test publish and subscribe | ||
| 1026 | |||
| 1027 | (% style="text-align:center" %) | ||
| 1028 | [[image:1624440014872-688.png||height="232" width="700" class="img-thumbnail"]] | ||
| 1029 | |||
| 1030 | (% style="text-align:center" %) | ||
| 1031 | [[image:1624440026937-386.png||height="215" width="700" class="img-thumbnail"]] | ||
| 1032 | |||
| 1033 | Huawei publish topic format: $oc/devices/{device_id}/sys/properties/report | ||
| 1034 | |||
| 1035 | (% style="text-align:center" %) | ||
| 1036 | [[image:1624440404119-815.png||class="img-thumbnail"]] | ||
| 1037 | |||
| 1038 | Huawei subscribe topic format: **$oc/devices/{device_id}/sys/commands/#** | ||
| 1039 | |||
| 1040 | (% style="text-align:center" %) | ||
| 1041 | [[image:1624447157493-672.png||class="img-thumbnail"]] | ||
| 1042 | |||
| 1043 | (% style="text-align:center" %) | ||
| 1044 | [[image:1624447209982-715.png||class="img-thumbnail"]] | ||
| 1045 | |||
| 1046 | (5).How to configure to view the received data format intuitively, multiple products (Huawei) are required to configure the model. The specific steps are as follows: | ||
| 1047 | ①Select the corresponding product from Huawei products to view | ||
| 1048 | |||
| 1049 | (% style="text-align:center" %) | ||
| 1050 | [[image:1624440647663-632.png||class="img-thumbnail"]] | ||
| 1051 | |||
| 1052 | ②Custom model: used to display the service ID name of the configuration report. | ||
| 1053 | |||
| 1054 | (% style="text-align:center" %) | ||
| 1055 | [[image:1624440793982-974.png||height="410" width="700" class="img-thumbnail"]] | ||
| 1056 | |||
| 1057 | (% style="text-align:center" %) | ||
| 1058 | [[image:1624440883015-105.png||height="370" width="600" class="img-thumbnail"]] | ||
| 1059 | |||
| 1060 | ③Add property, ID of monitoring point, and data format: | ||
| 1061 | |||
| 1062 | (% style="text-align:center" %) | ||
| 1063 | [[image:1624441052296-108.png||height="477" width="600" class="img-thumbnail"]] | ||
| 1064 | |||
| 1065 | ④After the configuration is complete, check the received data on the device | ||
| 1066 | |||
| 1067 | (% style="text-align:center" %) | ||
| 1068 | [[image:1624441186851-536.png||height="434" width="700" class="img-thumbnail"]] | ||
| 1069 | |||
| 1070 | == **2.5 V-Box connect with Huawei platform** == | ||
| 1071 | |||
| 1072 | In this demo,V-Box connects with Huawei by SSL certification. | ||
| 1073 | |||
| 1074 | 1.Create a project access for Huawei IOT | ||
| 1075 | |||
| 1076 | 2.configure MQTT configuration | ||
| 1077 | |||
| 1078 | (% style="text-align:center" %) | ||
| 1079 | [[image:1624506363847-661.png||height="507" width="1000" class="img-thumbnail"]] | ||
| 1080 | |||
| 1081 | 3.Create a script with the demo as below. | ||
| 1082 | |||
| 1083 | Script is as below | ||
| 1084 | |||
| 1085 | (% class="box infomessage" %) | ||
| 1086 | ((( | ||
| 1087 | (% class="box infomessage" %) | ||
| 1088 | ((( | ||
| 1089 | ~-~- mqtt.fx simulated access to Huawei Cloud IoT platform refer to 2.4 | ||
| 1090 | sprint = print | ||
| 1091 | |||
| 1092 | ~-~-Get custom configuration parameters (gateway customization information) | ||
| 1093 | local CUSTOM = bns_get_config("bind") | ||
| 1094 | local DS_ID = CUSTOM.DSID or "5dfa0700df1ae506179afb9c_wecon" | ||
| 1095 | |||
| 1096 | |||
| 1097 | ~-~-OpenCloud mode interface, obtain MQTT information configured on cloud platform: (5 returned, respectively server address, client ID, connection table, last word table, certificate table) | ||
| 1098 | local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg() | ||
| 1099 | |||
| 1100 | MQTT_CFG.username =DS_ID | ||
| 1101 | MQTT_CFG.password='d030d92338fcc18cd10fabb3003a4a0f6620fa6822cd3c23b1d9bc790200c6e7' | ||
| 1102 | MQTT_CLIENTID = '5dfa0700df1ae506179afb9c_wecon_0_0_2019121819' | ||
| 1103 | |||
| 1104 | ~-~-publish topic format:$oc/devices/{device id}/sys/properties/report | ||
| 1105 | |||
| 1106 | local pub_RE_TOPIC = string.format('$oc/devices/60a71ccbbbe12002c08f3a1a_WECON/sys/properties/report') | ||
| 1107 | |||
| 1108 | ~-~-variate | ||
| 1109 | local last_time = 0 | ||
| 1110 | |||
| 1111 | |||
| 1112 | ~-~-Timing principal function | ||
| 1113 | function hwyiot.main() | ||
| 1114 | |||
| 1115 | sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " hwyiot.main start") | ||
| 1116 | if g_mq then | ||
| 1117 | if g_mq:isconnected() then | ||
| 1118 | send_Data() | ||
| 1119 | else | ||
| 1120 | if os.time() - last_time > 20 then | ||
| 1121 | last_time = os.time() | ||
| 1122 | mymqtt_connect() | ||
| 1123 | end | ||
| 1124 | end | ||
| 1125 | else | ||
| 1126 | mymqtt_init() | ||
| 1127 | end | ||
| 1128 | sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " hwyiot.main end") | ||
| 1129 | end | ||
| 1130 | |||
| 1131 | ~-~- initializationMQTT | ||
| 1132 | function mymqtt_init() | ||
| 1133 | sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID)) | ||
| 1134 | g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable | ||
| 1135 | if g_mq then | ||
| 1136 | g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks | ||
| 1137 | sprint("mqtt init success") | ||
| 1138 | else | ||
| 1139 | sprint("mqtt init failed:", err) | ||
| 1140 | end | ||
| 1141 | end | ||
| 1142 | |||
| 1143 | ~-~- Connect to the MQTT server | ||
| 1144 | function mymqtt_connect() | ||
| 1145 | sprint("mqtt connecting...") | ||
| 1146 | local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART) | ||
| 1147 | if stat == nil then | ||
| 1148 | sprint("mqtt connect failed:", err) | ||
| 1149 | return | ||
| 1150 | else | ||
| 1151 | sprint("mqtt connected") | ||
| 1152 | end | ||
| 1153 | |||
| 1154 | ~-~-subscribe topic format:$oc/devices/{device_id}/sys/commands/# | ||
| 1155 | |||
| 1156 | g_mq:subscribe('$oc/devices/60a71ccbbbe12002c08f3a1a_WECON/sys/commands/#', 0) | ||
| 1157 | end | ||
| 1158 | |||
| 1159 | ~-~- Receive the message callback function | ||
| 1160 | function mymqtt_msg_callback(topic, msg) | ||
| 1161 | sprint("recv data!") | ||
| 1162 | sprint("topic:msg", topic,msg) | ||
| 1163 | print(msg) | ||
| 1164 | local revData = json.decode(msg) | ||
| 1165 | \\end | ||
| 1166 | |||
| 1167 | ~-~-Send data | ||
| 1168 | function send_Data() | ||
| 1169 | local pub_data = { | ||
| 1170 | msgType = 'deviceReq', | ||
| 1171 | data = ~{~{ | ||
| 1172 | serviceId ='Battery', | ||
| 1173 | serviceData={ | ||
| 1174 | batteryLevel = 55 | ||
| 1175 | } | ||
| 1176 | }} | ||
| 1177 | } | ||
| 1178 | return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0) | ||
| 1179 | end | ||
| 1180 | ))) | ||
| 1181 | ))) | ||
| 1182 | |||
| 1183 | 4.Download project access into V-Box to test in debug page | ||
| 1184 | |||
| 1185 | (% style="text-align:center" %) | ||
| 1186 | [[image:1624506710354-406.png||height="658" width="1000" class="img-thumbnail"]] | ||
| 1187 | |||
| 1188 | (% style="text-align:center" %) | ||
| 1189 | [[image:1624506666650-161.png||height="547" width="1000" class="img-thumbnail"]] | ||
| 1190 | |||
| 1191 | == **2.6 V-Box connect with AWS platform** == | ||
| 1192 | |||
| 1193 | === **Log in AWS** === | ||
| 1194 | |||
| 1195 | Login aws account and click“Connect an IoT device” | ||
| 1196 | |||
| 1197 | [[image:image-20220709165402-1.png]] | ||
| 1198 | |||
| 1199 | [[image:image-20220709165402-2.png]] | ||
| 1200 | |||
| 1201 | |||
| 1202 | === **Create policy** === | ||
| 1203 | |||
| 1204 | Click “Secure”~-~-->“Policies”~-~-->“Create policy”~-~-->Click “Create” | ||
| 1205 | |||
| 1206 | [[image:image-20220709165402-3.png]] | ||
| 1207 | |||
| 1208 | Name the policy~-~-->Click “JSON”~-~-->Copy the following content~-~-->Click “Create” | ||
| 1209 | |||
| 1210 | [[image:image-20220709165402-5.png]] | ||
| 1211 | |||
| 1212 | [[image:image-20220709165402-4.png]] | ||
| 1213 | |||
| 1214 | {{code language="java"}} | ||
| 1215 | { | ||
| 1216 | "Version": "2012-10-17", | ||
| 1217 | "Statement": [ | ||
| 1218 | { | ||
| 1219 | "Effect": "Allow", | ||
| 1220 | "Action": [ | ||
| 1221 | "iot:Connect", | ||
| 1222 | "iot:Publish", | ||
| 1223 | "iot:Subscribe", | ||
| 1224 | "iot:Receive", | ||
| 1225 | "greengrass:Discover" | ||
| 1226 | ], | ||
| 1227 | "Resource": "*" | ||
| 1228 | } | ||
| 1229 | ] | ||
| 1230 | } | ||
| 1231 | {{/code}} | ||
| 1232 | |||
| 1233 | === **Create things** === | ||
| 1234 | |||
| 1235 | Click “Manage”~-~-->“Things”~-~-->“Create things”~-~-->“Create single thing” | ||
| 1236 | |||
| 1237 | [[image:image-20220709165402-6.png]] | ||
| 1238 | |||
| 1239 | [[image:image-20220709165402-7.png]] | ||
| 1240 | |||
| 1241 | Name the thing~-~-->Click “Next” | ||
| 1242 | |||
| 1243 | [[image:image-20220709165402-8.png]] | ||
| 1244 | |||
| 1245 | Select the way to create certificate | ||
| 1246 | |||
| 1247 | [[image:image-20220709165402-9.png]] | ||
| 1248 | |||
| 1249 | Select policy | ||
| 1250 | |||
| 1251 | [[image:image-20220709165402-10.png]] | ||
| 1252 | |||
| 1253 | [[image:image-20220709165402-11.png]] | ||
| 1254 | |||
| 1255 | |||
| 1256 | === **Test with MQTT.fx tool** === | ||
| 1257 | |||
| 1258 | Click “View Setting” to get the “Broker Adress” | ||
| 1259 | |||
| 1260 | [[image:image-20220709165402-13.png]] | ||
| 1261 | |||
| 1262 | [[image:image-20220709165402-12.png]] | ||
| 1263 | |||
| 1264 | Create one connection in MQTT.fx tool, set broker port as 8883. | ||
| 1265 | |||
| 1266 | [[image:image-20220709165402-14.png]] | ||
| 1267 | |||
| 1268 | Upload the CA File, Client Certificate File, Client Key File | ||
| 1269 | |||
| 1270 | [[image:image-20220709165402-15.png]] | ||
| 1271 | |||
| 1272 | Publish message to topic “TEST” | ||
| 1273 | |||
| 1274 | [[image:image-20220709165402-17.png]] | ||
| 1275 | |||
| 1276 | Click”Test”~-~-->”MQTT test client”~-~-->”Subscrible to a topic”, to get message publish from MQTT.fx tool. | ||
| 1277 | |||
| 1278 | [[image:image-20220709173500-1.png]] | ||
| 1279 | |||
| 1280 | And we can also send message form AWS platform to MQTT.fx tool. | ||
| 1281 | |||
| 1282 | [[image:image-20220709165402-18.png]] | ||
| 1283 | |||
| 1284 | === **Configurate in CloudTool** === | ||
| 1285 | |||
| 1286 | Copy the same setting in MQTT.fx to MQTT configuration | ||
| 1287 | |||
| 1288 | [[image:image-20220709165402-19.png]] | ||
| 1289 | |||
| 1290 | Add a lua script and copy the lua demo into it. | ||
| 1291 | |||
| 1292 | [[image:image-20220709165402-20.png]] | ||
| 1293 | |||
| 1294 | {{info}} | ||
| 1295 | **✎Note:** Before using the following demo script, please make sure the V-Box firmware is newer than 22110701 | ||
| 1296 | {{/info}} | ||
| 1297 | |||
| 1298 | {{code language="lua"}} | ||
| 1299 | sprint = print | ||
| 1300 | |||
| 1301 | --Cloud mode interface to obtain the MQTT information configured by the cloud platform: (5 returns, namely the server address, client ID, connection table, last word table, certificate table) | ||
| 1302 | |||
| 1303 | local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg() | ||
| 1304 | |||
| 1305 | --publish to topics | ||
| 1306 | |||
| 1307 | local pub_RE_TOPIC = string.format('TEST') | ||
| 1308 | |||
| 1309 | --Subscribe topics | ||
| 1310 | |||
| 1311 | local Subscribe_RE_TOPIC1 = string.format('TEST') | ||
| 1312 | |||
| 1313 | --variable | ||
| 1314 | |||
| 1315 | local last_time = 0 | ||
| 1316 | |||
| 1317 | --Timing main function | ||
| 1318 | |||
| 1319 | function aws.main() | ||
| 1320 | |||
| 1321 | sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start") | ||
| 1322 | |||
| 1323 | if g_mq then | ||
| 1324 | |||
| 1325 | if g_mq:isconnected() then | ||
| 1326 | |||
| 1327 | send_Data() | ||
| 1328 | |||
| 1329 | else | ||
| 1330 | |||
| 1331 | if os.time() - last_time > 5 then | ||
| 1332 | |||
| 1333 | last_time = os.time() | ||
| 1334 | |||
| 1335 | mymqtt_connect() | ||
| 1336 | |||
| 1337 | end | ||
| 1338 | |||
| 1339 | end | ||
| 1340 | |||
| 1341 | else | ||
| 1342 | |||
| 1343 | mymqtt_init() | ||
| 1344 | |||
| 1345 | end | ||
| 1346 | |||
| 1347 | sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end") | ||
| 1348 | |||
| 1349 | end | ||
| 1350 | |||
| 1351 | |||
| 1352 | |||
| 1353 | -- Initialize MQTT | ||
| 1354 | |||
| 1355 | function mymqtt_init() | ||
| 1356 | |||
| 1357 | sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID)) | ||
| 1358 | |||
| 1359 | g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID, 1) -- Create the object and declare it as a global variable, 1 means using the domain to connect | ||
| 1360 | |||
| 1361 | if g_mq then | ||
| 1362 | |||
| 1363 | g_mq:on("message", mymqtt_msg_callback) -- Register to receive message callbacks | ||
| 1364 | |||
| 1365 | sprint("mqtt init success") | ||
| 1366 | |||
| 1367 | else | ||
| 1368 | |||
| 1369 | sprint("mqtt init failed:", err) | ||
| 1370 | |||
| 1371 | end | ||
| 1372 | |||
| 1373 | end | ||
| 1374 | |||
| 1375 | -- Connect to MQTT server | ||
| 1376 | |||
| 1377 | function mymqtt_connect() | ||
| 1378 | |||
| 1379 | sprint("mqtt connecting...") | ||
| 1380 | |||
| 1381 | local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART) | ||
| 1382 | |||
| 1383 | if stat == nil then | ||
| 1384 | |||
| 1385 | sprint("mqtt connect failed:", err) | ||
| 1386 | |||
| 1387 | return | ||
| 1388 | |||
| 1389 | else | ||
| 1390 | |||
| 1391 | sprint("mqtt connected") | ||
| 1392 | |||
| 1393 | end | ||
| 1394 | |||
| 1395 | g_mq:subscribe(Subscribe_RE_TOPIC1, 0) | ||
| 1396 | |||
| 1397 | end | ||
| 1398 | |||
| 1399 | -- Receive MQTT message callback function | ||
| 1400 | |||
| 1401 | function mymqtt_msg_callback(topic, msg) | ||
| 1402 | |||
| 1403 | print("topic:",topic) | ||
| 1404 | |||
| 1405 | print("revdata:",msg) | ||
| 1406 | |||
| 1407 | local revData = json.decode(msg) | ||
| 1408 | |||
| 1409 | print (revData) | ||
| 1410 | |||
| 1411 | if topic == Subscribe_RE_TOPIC1 then --Process topic information subscribed from the cloud | ||
| 1412 | |||
| 1413 | if string.match(topic,Subscribe_RE_TOPIC1) then | ||
| 1414 | |||
| 1415 | --if revData ~= nil then | ||
| 1416 | |||
| 1417 | for k,v in pairs (revData) do | ||
| 1418 | |||
| 1419 | print("printing revdata after kv here") | ||
| 1420 | |||
| 1421 | print (k,v) | ||
| 1422 | |||
| 1423 | end | ||
| 1424 | |||
| 1425 | print ("current state is",fanstate) | ||
| 1426 | |||
| 1427 | --end | ||
| 1428 | |||
| 1429 | end | ||
| 1430 | |||
| 1431 | end | ||
| 1432 | |||
| 1433 | end | ||
| 1434 | |||
| 1435 | |||
| 1436 | |||
| 1437 | --Get real-time data | ||
| 1438 | |||
| 1439 | function getData() | ||
| 1440 | |||
| 1441 | local jdata = {} | ||
| 1442 | |||
| 1443 | local addr = bns_get_alldata() | ||
| 1444 | |||
| 1445 | print(json.encode(addr)) | ||
| 1446 | |||
| 1447 | for i,v in pairs(addr) do | ||
| 1448 | |||
| 1449 | if v[2] == 1 then | ||
| 1450 | |||
| 1451 | jdata[v[3]] = v[4] | ||
| 1452 | |||
| 1453 | end | ||
| 1454 | |||
| 1455 | end | ||
| 1456 | |||
| 1457 | return jdata | ||
| 1458 | |||
| 1459 | end | ||
| 1460 | |||
| 1461 | --send data | ||
| 1462 | |||
| 1463 | function send_Data() | ||
| 1464 | |||
| 1465 | local pub_data = | ||
| 1466 | { | ||
| 1467 | 123 | ||
| 1468 | } | ||
| 1469 | |||
| 1470 | sprint(json.encode(pub_data)) | ||
| 1471 | |||
| 1472 | print("..........",pub_RE_TOPIC) | ||
| 1473 | |||
| 1474 | return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0) | ||
| 1475 | |||
| 1476 | end | ||
| 1477 | {{/code}} | ||
| 1478 | |||
| 1479 | Get message in AWS | ||
| 1480 | |||
| 1481 | [[image:image-20220709165402-21.png]] |