Changes for page 2 Script
Last modified by Devin Chen on 2025/06/06 14:03
Summary
-
Page properties (1 modified, 0 added, 0 removed)
-
Attachments (0 modified, 0 added, 1 removed)
Details
- Page properties
-
- Content
-
... ... @@ -70,12 +70,6 @@ 70 70 71 71 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. 72 72 73 -As for How to get the botToken and chatID, please check the followig videos: 74 - 75 -[[https:~~/~~/www.youtube.com/watch?v=zh6yYlnjX7k>>https://www.youtube.com/watch?v=zh6yYlnjX7k]] 76 - 77 -[[https:~~/~~/www.youtube.com/watch?v=Pj8mwuMZZvg>>https://www.youtube.com/watch?v=Pj8mwuMZZvg]] 78 - 79 79 {{code language="Lua"}} 80 80 local tempBit = 0 81 81 local tempWord = 0 ... ... @@ -220,233 +220,6 @@ 220 220 end 221 221 {{/code}} 222 222 223 -== **1.7 Twilio WhatsApp Messaging** == 224 - 225 -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. 226 - 227 -About how to register the Twilio API, please check the following video: 228 - 229 -[[https:~~/~~/www.youtube.com/watch?v=Id4lKichauU>>https://www.youtube.com/watch?v=Id4lKichauU]] 230 - 231 -{{code language="Lua"}} 232 -local tempBit = 0 233 -local tempWord = 0 234 - 235 -local https = require("https") 236 -local json = require("json") 237 -local ltn12 = require("ltn12") 238 - 239 -local SID = 'AC1703bd710ffa98006d2bcc0b********' 240 -local Token = 'd3c11897623c39e538b20263ec19****' 241 - 242 -local twilioPhoneNumber = '+14155238886' 243 -local receiverPhoneNumber = '+8615880018277' 244 - 245 -local b='ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/' 246 -function encodingBase64(data) 247 - return ((data:gsub('.', function(x) 248 - local r,b='',x:byte() 249 - for i=8,1,-1 do r=r..(b%2^i-b%2^(i-1)>0 and '1' or '0') end 250 - return r; 251 - end)..'0000'):gsub('%d%d%d?%d?%d?%d?', function(x) 252 - if (#x < 6) then return '' end 253 - local c=0 254 - for i=1,6 do c=c+(x:sub(i,i)=='1' and 2^(6-i) or 0) end 255 - return b:sub(c+1,c+1) 256 - end)..({ '', '==', '=' })[#data%3+1]) 257 -end 258 - 259 -function encodeUrl(str) 260 - str = string.gsub(str, "([^%w%.%- ])", function(c) 261 - return string.format("%%%02X", string.byte(c)) end) 262 - return string.gsub(str, " ", "+") 263 -end 264 - 265 - 266 - 267 - 268 -function requestBodySplice(message, sender, receiver) 269 - local reqBody = '' 270 - local encodeMess = encodeUrl(message) 271 - local encodeSend = encodeUrl(sender) 272 - local encodeRece = encodeUrl(receiver) 273 - --reqBody = "Body=Hello%20Wecon2&From=whatsapp%3A%2B14155238886&To=whatsapp%3A%2B8615880018277" 274 - reqBody = string.format("Body=%s&From=whatsapp:%s&To=whatsapp:%s", encodeMess, encodeSend, encodeRece) 275 - print(reqBody) 276 - return reqBody 277 -end 278 - 279 - 280 --- Send http.get request and return response result 281 -function getHttpsUrl(url,header,reqbody) 282 - local body = {} 283 - local bodyJson = json.encode(body) 284 - local result_table, code, headers, status = https.request{ 285 - method = "POST", 286 - url = url, 287 - source = ltn12.source.string(reqbody), 288 - headers = header, 289 - sink = ltn12.sink.table(body) 290 - } 291 - print("code:"..code) 292 - if code~= 200 then 293 - return 294 - else 295 - return body 296 - end 297 -end 298 - 299 -function getMessageUrl(whatsAppMessage) 300 - local auth = SID..':'..Token 301 - local url = "https://api.twilio.com/2010-04-01/Accounts/"..SID.."/Messages" 302 - --local reqMess = "message="..twilioMessage 303 - local reqMess = requestBodySplice(whatsAppMessage, twilioPhoneNumber, receiverPhoneNumber) 304 - local headers = 305 - { 306 - ["Authorization"] = "Basic "..encodingBase64(auth), 307 - ["Content-Type"] = "application/x-www-form-urlencoded", 308 - ["Content-Length"] = #reqMess 309 - } 310 - 311 - print("Get the link:"..url) 312 - getHttpsUrl(url, headers, reqMess) 313 -end 314 - 315 - 316 - 317 -function Twilio.main() 318 - --dosomething 319 - --local auth = SID..':'..Token 320 - --print(requestBodySplice("HelloWorld", twilioPhoneNumber, receiverPhoneNumber)) 321 - --print(encodingBase64(auth)) 322 - local bitValue = addr_getbit("@testBit"); 323 - local message = '' 324 - print("b=="..bitValue) 325 - if bitValue == 1 and bitValue ~= tempBit then 326 - message = 'Alarm V-Box triggered, the output is '.. bitValue 327 - getMessageUrl(message) 328 - print("Notification pushed of triggering alarm,"..bitValue) 329 - elseif bitValue == 0 and bitValue ~= tempBit then 330 - message = 'Alarm V-Box dismissed, the output is '.. bitValue 331 - getMessageUrl(message) 332 - print("Notification pushed of dismissing alarm,"..bitValue) 333 - end 334 - tempBit = bitValue----Prevent monitoring values from continuous being sent to the platform 335 - 336 - local wordValue = addr_getword("@testWord") 337 - print("w=="..wordValue) 338 - --dosomething 339 - if wordValue >= 100 and wordValue ~= tempWord and tempWord <= 100 then 340 - message = 'Alarm V-Box triggered, the temperature is '.. wordValue 341 - getMessageUrl(message) 342 - print("Notification pushed of triggering alarm,"..wordValue) 343 - elseif wordValue < 100 and wordValue ~= tempWord and tempWord >= 100 then 344 - message = 'Alarm V-Box dismissed, the temperature is '.. wordValue 345 - getMessageUrl(message) 346 - print("Notification pushed of dismissing alarm,"..wordValue) 347 - end 348 - tempWord = wordValue----Prevent monitoring values from continuous being sent to the platform 349 -end 350 -{{/code}} 351 - 352 -== **1.8 How to parse value from HTTP response body** == 353 - 354 -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": 355 - 356 -(% style="text-align:center" %) 357 -[[image:InputHTTPparameter.png]] 358 - 359 -Then the response body would be like as following: 360 - 361 -{{code language="json"}} 362 -{ 363 - "location": { 364 - "name": "Madrid", 365 - "region": "Madrid", 366 - "country": "Spain", 367 - "lat": 40.4, 368 - "lon": -3.68, 369 - "tz_id": "Europe/Madrid", 370 - "localtime_epoch": 1669022636, 371 - "localtime": "2022-11-21 10:23" 372 - }, 373 - "current": { 374 - "last_updated_epoch": 1669022100, 375 - "last_updated": "2022-11-21 10:15", 376 - "temp_c": 13.0, 377 - "temp_f": 55.4, 378 - "is_day": 1, 379 - "condition": { 380 - "text": "Partly cloudy", 381 - "icon": "//cdn.weatherapi.com/weather/64x64/day/116.png", 382 - "code": 1003 383 - }, 384 - "wind_mph": 11.9, 385 - "wind_kph": 19.1, 386 - "wind_degree": 210, 387 - "wind_dir": "SSW", 388 - "pressure_mb": 1015.0, 389 - "pressure_in": 29.97, 390 - "precip_mm": 0.0, 391 - "precip_in": 0.0, 392 - "humidity": 88, 393 - "cloud": 75, 394 - "feelslike_c": 10.8, 395 - "feelslike_f": 51.4, 396 - "vis_km": 10.0, 397 - "vis_miles": 6.0, 398 - "uv": 3.0, 399 - "gust_mph": 22.1, 400 - "gust_kph": 35.6 401 - } 402 -} 403 -{{/code}} 404 - 405 -(% class="wikigeneratedid" %) 406 -So we decode json into lua object to assign the value into addresses HDW6060(temperature), HDW7070(humidity), the code example like follows: 407 - 408 -{{code language="lua"}} 409 -local APIkey = '70faaecf926b4341b1974006221711' 410 - 411 - 412 -local http = require("socket.http") 413 -local json = require("json") 414 - 415 --- Send http.get request and return response result 416 -function getHttpsUrl(url) 417 - local result_table, code, headers, status = http.request(url) 418 - print("code:"..code) 419 - if code~= 200 then 420 - return 421 - else 422 - return result_table 423 - end 424 -end 425 - 426 -function sendAPI(key, city) 427 - local url = "http://api.weatherapi.com/v1/current.json?key="..key.."&q="..city.."&aqi=no" 428 - --local url = 'http://v-box.net' 429 - --local url = 'https://www.google.com/' 430 - --http://api.weatherapi.com/v1/current.json?key=70faaecf926b4341b1974006221711&q=Barcelona&aqi=no 431 - print("Get the link:"..url) 432 - local body = getHttpsUrl(url) 433 - --print(body) 434 - local jsonBody = json.decode(body) 435 - --print(jsonBody["current"]["temp_c"]) 436 - --print(type(jsonBody["current"]["temp_c"])) 437 - --print(type(jsonBody["current"]["humidity"])) 438 - addr_setfloat("@HDW6060", jsonBody["current"]["temp_c"]) 439 - addr_setword("@HDW7070", jsonBody["current"]["humidity"]) 440 -end 441 - 442 - 443 -function Weather.main() 444 - local cityName = addr_getstring("@HDW5050",6) 445 - print("cityName: "..cityName) 446 - sendAPI(APIkey, cityName) 447 -end 448 -{{/code}} 449 - 450 450 = **2 V-Box connect with third part server** = 451 451 452 452 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. ... ... @@ -599,134 +599,142 @@ 599 599 -- Meta class 600 600 --main 601 601 function mq.main() 602 - 603 - 369 + if not mq.m then 370 + local err = "" 604 604 605 - mq.m, err = mqtt.create("tcp://grouprobotinfo.com:1883", "ClienID") -- create connection 606 - if mq.m then 607 - mq.config = { 608 - username = "",-- ID 609 - password = "",-- password 610 - netway = 1, -- Ethernet connection, WIFI=1 611 - -- keepalive = 100, -- Optional, set the connection heartbeat interval for 100 seconds. 612 - -- cleansession = 0, -- Optional, keep session 613 - } 614 - mq.m:on("message", function(topic, msg) -- Register for receiving message callbacks 615 - local str = string.format("%s:%s", topic, msg) 616 - -- print("mqtt msg:", str) -- Print out the received topics and content 617 - end) 618 - mq.m:on("offline", function (cause) -- Register for lost connection callbacks 619 - -- addr_setstring("@xxx", "cause"..(cause or " got nil")) 620 - end) 621 - mq.m:on("arrived", function() -- Registration for sending messages to callbacks 622 - print("msg arrived") 623 - end) 624 - else 625 - print("mqtt create failed:", err) -- Create object failed 626 - end 627 - else 628 - if mq.m:isconnected() then -- If online, post a message 629 - local phaseStatus ="unknow" 630 - if addr_getbit("@Standby")== 1 then 631 - phaseStatus = "Standby" 632 - elseif addr_getbit("@Pre-Freeze")==1 then 633 - phaseStatus= "Pre-Freeze" 634 - elseif addr_getbit("@Prepare")==1 then 635 - phaseStatus ="Prepare" 636 - elseif addr_getbit("@Primary Dry")==1 then 637 - phaseStatus = "Primary dry" 638 - elseif addr_getbit("@Secondary Dry")==1 then 639 - phaseStatus = "Secondary Dry" 640 - end 641 - --print(addr_getbit("@Primary Dry")) 372 + mq.m, err = mqtt.create("tcp://grouprobotinfo.com:1883", "ClienID") -- create connection 373 + if mq.m then 374 + mq.config = { 375 + username = "",-- ID 376 + password = "",-- password 377 + netway = 1, -- Ethernet connection, WIFI=1 378 + -- keepalive = 100, -- Optional, set the connection heartbeat interval for 100 seconds. 379 + -- cleansession = 0, -- Optional, keep session 380 + } 381 + mq.m:on("message", function(topic, msg) -- Register for receiving message callbacks 382 + local str = string.format("%s:%s", topic, msg) 383 + -- print("mqtt msg:", str) -- Print out the received topics and content 384 + end 385 + ) 386 + mq.m:on("offline", function (cause) -- Register for lost connection callbacks 387 + -- addr_setstring("@xxx", "cause"..(cause or " got nil")) 388 + end) 389 + mq.m:on("arrived", function() -- Registration for sending messages to callbacks 390 + print("msg arrived") 391 + end) 392 + else 393 + print("mqtt create failed:", err) -- Create object failed 394 + end 395 + else 396 + if mq.m:isconnected() then -- If online, post a message 397 + local phaseStatus ="unknow" 398 + if addr_getbit("@Standby")== 1 then 399 + phaseStatus = "Standby" 400 + elseif addr_getbit("@Pre-Freeze")==1 then 401 + phaseStatus= "Pre-Freeze" 402 + elseif addr_getbit("@Prepare")==1 then 403 + phaseStatus ="Prepare" 404 + elseif addr_getbit("@Primary Dry")==1 then 405 + phaseStatus = "Primary dry" 406 + elseif addr_getbit("@Secondary Dry")==1 then 407 + phaseStatus = "Secondary Dry" 408 + end 409 +-- print(addr_getbit("@Primary Dry")) 642 642 ------------------------------------------------------------------------------------------------------------------------- 643 - local activating ="unknow" 644 - if addr_getbit("@Compressor")==1 then 645 - activating = ",".."Compressor" 646 - end 647 - if addr_getbit("@Silicone Pump")==1 then 648 - activating = activating..",".."Silicone Pump" 649 - end 650 - if addr_getbit("@Vacuum Pump")==1 then 651 - activating = activating..",".."Vacuum Pump" 652 - end 653 - if addr_getbit("@Root Pump")==1 then 654 - activating = activating..",".."Root Pump" 655 - end 656 - if addr_getbit("@Heater")==1 then 657 - activating = activating..",".."Heater" 658 - end 659 - if addr_getbit("@Valve Silicone")==1 then 660 - activating = activating..",".."Valve Silicone" 661 - end 662 - if addr_getbit("@Valve Ice Condenser")==1 then 663 - activating = activating..",".."Valve Ice Condenser" 664 - end 665 - if addr_getbit("@Valve Vacuum Pump")==1 then 666 - activating = activating..",".."Valve Vacuum Pump" 667 - end 668 - local pr_activating =string.sub(activating,2) 669 - -- print(pr_activating) 670 - local status_text ="unknow" 671 - if addr_getbit("@Status Run")==1 then 672 - status_text = "RUNNING" 673 - else 674 - status_text = "STOP" 675 - end 676 -------------------------------------------------------------------------------------------------------------------------- 677 - local js = {type="status", 678 - mc_name ="FD300", 679 - status=status_text, 680 - elapsed_time={ 681 - hour=addr_getword("@Elapsed Time (Hour)"), 682 - min=addr_getword("@Elapsed Time (Minute)"), 683 - sec=addr_getword("@Elapsed Time (Second)") 684 - }, 685 - phase = phaseStatus, 686 - step = addr_getword("@Step"), 687 - activating_output = pr_activating, 688 - sv=addr_getshort("@SV Silicone")/10, 689 - pv=addr_getshort("@PV Silicone")/10, 690 - product1=addr_getshort("@Product 1")/10, 411 + local activating ="unknow" 412 + if addr_getbit("@Compressor")==1 then 413 + activating = ",".."Compressor" 414 + end 415 + if addr_getbit("@Silicone Pump")==1 then 416 + activating = activating..",".."Silicone Pump" 417 + end 418 + if addr_getbit("@Vacuum Pump")==1 then 419 + activating = activating..",".."Vacuum Pump" 420 + end 421 + if addr_getbit("@Root Pump")==1 then 422 + activating = activating..",".."Root Pump" 423 + end 424 + if addr_getbit("@Heater")==1 then 425 + activating = activating..",".."Heater" 426 + end 427 + if addr_getbit("@Valve Silicone")==1 then 428 + activating = activating..",".."Valve Silicone" 429 + end 430 + if addr_getbit("@Valve Ice Condenser")==1 then 431 + activating = activating..",".."Valve Ice Condenser" 432 + end 433 + if addr_getbit("@Valve Vacuum Pump")==1 then 434 + activating = activating..",".."Valve Vacuum Pump" 435 + end 436 + local pr_activating =string.sub(activating,2) 437 + -- print(pr_activating) 691 691 692 - product2=addr_getshort("@Product 2")/10, 693 - product3=addr_getshort("@Product 3")/10, 694 - product4=addr_getshort("@Product 4")/10, 695 - ice1=addr_getshort("@Ice condenser 1")/10, 696 - ice2=addr_getshort("@Ice condenser 2")/10, 697 - vacuum=addr_getfloat("@Vacuum") 698 - } 699 - local jsAlarm = { HPC = addr_getbit("@B_25395#W0.00"), 700 - ODPC = addr_getbit("@B_25395#W0.01"), 701 - MTPC=addr_getbit("@B_25395#W0.02"), 702 - HTT = addr_getbit("@B_25395#W1.03"), 703 - CPC = addr_getbit("@B_25395#W0.08"), 704 - CPSP =addr_getbit("@B_25395#W1.00"), 705 - CPVP =addr_getbit("@B_25395#W0.10"), 706 - CPRP =addr_getbit("@B_25395#W0.11"), 707 - HP =addr_getbit("@B_25395#W1.01"), 708 - PP= addr_getbit("@B_25395#W1.02"), 709 - PO=addr_getbit("@B_25395#W0.07"), 710 - FSE=addr_getbit("@B_25395#W2.04"), 711 - AVVSVV=addr_getbit("@B_25395#W1.12"), 712 - ICHT=addr_getbit("@B_25395#W3.06") 713 - } 714 - -- ("@B_25395#CIO1.02") 715 - mq.m:publish("mqtt-v-box-epsilon-fd300", json.encode(js) , 0, 0) 716 - mq.m:publish("mqtt-v-box-epsilon-alarm-fd300", json.encode(jsAlarm) , 0, 0) 717 - else 718 - local stat, err = mq.m:connect(mq.config) -- connection 719 - if stat == nil then --Determine whether to connect 720 - print("mqtt connect failed:", err) 721 - return -- Connection failed, return directly 722 - end 723 - mq.m:subscribe("mqtt-v-box-epsilon", 0)-- Subscribe to topics 724 724 725 - end 726 - -- mq.m:unsubscribe("stc/test") 727 - -- mq.m:disconnect() -- close matt 728 - -- mq.m:close() -- close clase 729 - end 440 + 441 + local status_text ="unknow" 442 + if addr_getbit("@Status Run")==1 then 443 + status_text = "RUNNING" 444 + else 445 + status_text = "STOP" 446 + end 447 +------------------------------------------------------------------------------------------------------------------------- 448 + 449 + local js = {type="status", 450 + mc_name ="FD300", 451 + status=status_text, 452 + elapsed_time={ 453 + hour=addr_getword("@Elapsed Time (Hour)"), 454 + min=addr_getword("@Elapsed Time (Minute)"), 455 + sec=addr_getword("@Elapsed Time (Second)") 456 + }, 457 + phase = phaseStatus, 458 + step = addr_getword("@Step"), 459 + activating_output = pr_activating, 460 + sv=addr_getshort("@SV Silicone")/10, 461 + pv=addr_getshort("@PV Silicone")/10, 462 + product1=addr_getshort("@Product 1")/10, 463 + 464 + product2=addr_getshort("@Product 2")/10, 465 + product3=addr_getshort("@Product 3")/10, 466 + product4=addr_getshort("@Product 4")/10, 467 + ice1=addr_getshort("@Ice condenser 1")/10, 468 + ice2=addr_getshort("@Ice condenser 2")/10, 469 + vacuum=addr_getfloat("@Vacuum") 470 + 471 + } 472 + local jsAlarm = { HPC = addr_getbit("@B_25395#W0.00"), 473 + ODPC = addr_getbit("@B_25395#W0.01"), 474 + MTPC=addr_getbit("@B_25395#W0.02"), 475 + HTT = addr_getbit("@B_25395#W1.03"), 476 + CPC = addr_getbit("@B_25395#W0.08"), 477 + CPSP =addr_getbit("@B_25395#W1.00"), 478 + CPVP =addr_getbit("@B_25395#W0.10"), 479 + CPRP =addr_getbit("@B_25395#W0.11"), 480 + HP =addr_getbit("@B_25395#W1.01"), 481 + PP= addr_getbit("@B_25395#W1.02"), 482 + PO=addr_getbit("@B_25395#W0.07"), 483 + FSE=addr_getbit("@B_25395#W2.04"), 484 + AVVSVV=addr_getbit("@B_25395#W1.12"), 485 + ICHT=addr_getbit("@B_25395#W3.06") 486 + 487 + } 488 + 489 + -- ("@B_25395#CIO1.02") 490 + mq.m:publish("mqtt-v-box-epsilon-fd300", json.encode(js) , 0, 0) 491 + mq.m:publish("mqtt-v-box-epsilon-alarm-fd300", json.encode(jsAlarm) , 0, 0) 492 + else 493 + local stat, err = mq.m:connect(mq.config) -- connection 494 + if stat == nil then --Determine whether to connect 495 + print("mqtt connect failed:", err) 496 + return -- Connection failed, return directly 497 + end 498 + mq.m:subscribe("mqtt-v-box-epsilon", 0)-- Subscribe to topics 499 + 500 + end 501 + -- mq.m:unsubscribe("stc/test") 502 + -- mq.m:disconnect() -- close matt 503 + -- mq.m:close() -- close clase 504 + end 730 730 end 731 731 {{/code}} 732 732 ... ... @@ -1156,20 +1156,35 @@ 1156 1156 1157 1157 {{code language="java"}} 1158 1158 { 934 + 1159 1159 "Version": "2012-10-17", 936 + 1160 1160 "Statement": [ 938 + 1161 1161 { 940 + 1162 1162 "Effect": "Allow", 942 + 1163 1163 "Action": [ 944 + 1164 1164 "iot:Connect", 946 + 1165 1165 "iot:Publish", 948 + 1166 1166 "iot:Subscribe", 950 + 1167 1167 "iot:Receive", 952 + 1168 1168 "greengrass:Discover" 954 + 1169 1169 ], 956 + 1170 1170 "Resource": "*" 958 + 1171 1171 } 960 + 1172 1172 ] 962 + 1173 1173 } 1174 1174 {{/code}} 1175 1175 ... ... @@ -1234,186 +1234,185 @@ 1234 1234 1235 1235 [[image:image-20220709165402-20.png]] 1236 1236 1237 -{{code language="lua"}} 1238 1238 sprint = print 1239 1239 1240 ---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) 1029 +~-~-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) 1241 1241 1242 1242 local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg() 1243 1243 1244 ---publish to topics 1033 +~-~-publish to topics 1245 1245 1246 1246 local pub_RE_TOPIC = string.format('TEST') 1247 1247 1248 ---Subscribe topics 1037 +~-~-Subscribe topics 1249 1249 1250 1250 local Subscribe_RE_TOPIC1 = string.format('TEST') 1251 1251 1252 ---variable 1041 +~-~-variable 1253 1253 1254 1254 local last_time = 0 1255 1255 1256 ---Timing main function 1045 +~-~-Timing main function 1257 1257 1258 1258 function aws.main() 1259 1259 1260 - 1049 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start") 1261 1261 1262 - 1051 + if g_mq then 1263 1263 1264 - 1053 + if g_mq:isconnected() then 1265 1265 1266 - 1055 + send_Data() 1267 1267 1268 - 1057 + else 1269 1269 1270 - 1059 + if os.time() - last_time > 5 then 1271 1271 1272 - 1061 + last_time = os.time() 1273 1273 1274 - 1063 + mymqtt_connect() 1275 1275 1276 - end 1277 - 1278 1278 end 1279 1279 1280 - lse1067 + end 1281 1281 1282 - mymqtt_init()1069 + else 1283 1283 1284 - end1071 + mymqtt_init() 1285 1285 1286 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.mainend")1073 + end 1287 1287 1075 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end") 1076 + 1288 1288 end 1289 1289 1290 1290 1080 +~-~- Initialize MQTT 1291 1291 1292 --- Initialize MQTT 1293 - 1294 1294 function mymqtt_init() 1295 1295 1296 - 1084 + sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID)) 1297 1297 1298 - 1086 + g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable 1299 1299 1300 - 1088 + if g_mq then 1301 1301 1302 - 1090 + g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks 1303 1303 1304 - 1092 + sprint("mqtt init success") 1305 1305 1306 - 1094 + else 1307 1307 1308 - 1096 + sprint("mqtt init failed:", err) 1309 1309 1310 - 1098 + end 1311 1311 1312 1312 end 1313 1313 1314 --- Connect to MQTT server 1102 +~-~- Connect to MQTT server 1315 1315 1316 1316 function mymqtt_connect() 1317 1317 1318 - 1106 + sprint("mqtt connecting...") 1319 1319 1320 - 1108 + local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART) 1321 1321 1322 - 1110 + if stat == nil then 1323 1323 1324 - 1112 + sprint("mqtt connect failed:", err) 1325 1325 1326 - 1114 + return 1327 1327 1328 - 1116 + else 1329 1329 1330 - 1118 + sprint("mqtt connected") 1331 1331 1332 - 1120 + end 1333 1333 1334 - 1122 + g_mq:subscribe(TEST, 0) 1335 1335 1336 1336 end 1337 1337 1338 --- Receive MQTT message callback function 1126 +~-~- Receive MQTT message callback function 1339 1339 1340 1340 function mymqtt_msg_callback(topic, msg) 1341 1341 1342 - 1130 + print("topic:",topic) 1343 1343 1344 - 1132 + print("revdata:",msg) 1345 1345 1346 - 1134 + local revData = json.decode(msg) 1347 1347 1348 - 1136 + print (revData) 1349 1349 1350 - 1138 + if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud 1351 1351 1352 - 1140 +if string.match(topic,Subscribe_RE_TOPIC1) then 1353 1353 1354 - 1142 + ~-~-if revData ~~= nil then 1355 1355 1356 - 1144 + for k,v in pairs (revData) do 1357 1357 1358 - 1146 + print("printing revdata after kv here") 1359 1359 1360 - 1148 + print (k,v) 1361 1361 1362 - 1150 + end 1363 1363 1364 - 1152 + print ("current state is",fanstate) 1365 1365 1366 - 1154 + ~-~-end 1367 1367 1368 - 1156 +end 1369 1369 1370 - 1158 +end 1371 1371 1372 1372 end 1373 1373 1374 1374 1163 +~-~-Get real-time data 1375 1375 1376 ---Get real-time data 1377 - 1378 1378 function getData() 1379 1379 1380 - 1167 + local jdata = {} 1381 1381 1382 - 1169 + local addr = bns_get_alldata() 1383 1383 1384 - 1171 + print(json.encode(addr)) 1385 1385 1386 - 1173 + for i,v in pairs(addr) do 1387 1387 1388 - 1175 + if v[2] == 1 then 1389 1389 1390 - 1177 + jdata[v[3]] = v[4] 1391 1391 1392 - 1179 + end 1393 1393 1394 - 1181 + end 1395 1395 1396 - 1183 + return jdata 1397 1397 1398 1398 end 1399 1399 1400 ---send data 1187 +~-~-send data 1401 1401 1402 1402 function send_Data() 1403 1403 1404 - local pub_data = 1405 - { 1406 - 123 1407 - } 1191 + local pub_data = 1408 1408 1193 + { 1194 + 1195 +123 1196 + 1197 +} 1198 + 1409 1409 sprint(json.encode(pub_data)) 1410 1410 1411 1411 print("..........",pub_RE_TOPIC) 1412 1412 1413 - 1203 + return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0) 1414 1414 1415 1415 end 1416 -{{/code}} 1417 1417 1418 1418 Get message in AWS 1419 1419
- InputHTTPparameter.png
-
- Author
-
... ... @@ -1,1 +1,0 @@ 1 -XWiki.Hunter - Size
-
... ... @@ -1,1 +1,0 @@ 1 -17.9 KB - Content