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, 1 added, 0 removed)
Details
- Page properties
-
- Content
-
... ... @@ -70,6 +70,12 @@ 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 + 73 73 {{code language="Lua"}} 74 74 local tempBit = 0 75 75 local tempWord = 0 ... ... @@ -214,6 +214,233 @@ 214 214 end 215 215 {{/code}} 216 216 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 + 217 217 = **2 V-Box connect with third part server** = 218 218 219 219 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. ... ... @@ -366,142 +366,134 @@ 366 366 -- Meta class 367 367 --main 368 368 function mq.main() 369 - 370 - 602 + if not mq.m then 603 + local err = "" 371 371 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")) 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")) 410 410 ------------------------------------------------------------------------------------------------------------------------- 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) 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, 438 438 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 439 439 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 725 + end 726 + -- mq.m:unsubscribe("stc/test") 727 + -- mq.m:disconnect() -- close matt 728 + -- mq.m:close() -- close clase 729 + end 505 505 end 506 506 {{/code}} 507 507 ... ... @@ -931,35 +931,20 @@ 931 931 932 932 {{code language="java"}} 933 933 { 934 - 935 935 "Version": "2012-10-17", 936 - 937 937 "Statement": [ 938 - 939 939 { 940 - 941 941 "Effect": "Allow", 942 - 943 943 "Action": [ 944 - 945 945 "iot:Connect", 946 - 947 947 "iot:Publish", 948 - 949 949 "iot:Subscribe", 950 - 951 951 "iot:Receive", 952 - 953 953 "greengrass:Discover" 954 - 955 955 ], 956 - 957 957 "Resource": "*" 958 - 959 959 } 960 - 961 961 ] 962 - 963 963 } 964 964 {{/code}} 965 965 ... ... @@ -1024,185 +1024,186 @@ 1024 1024 1025 1025 [[image:image-20220709165402-20.png]] 1026 1026 1237 +{{code language="lua"}} 1027 1027 sprint = print 1028 1028 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)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) 1030 1030 1031 1031 local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg() 1032 1032 1033 - ~-~-publish to topics1244 +--publish to topics 1034 1034 1035 1035 local pub_RE_TOPIC = string.format('TEST') 1036 1036 1037 - ~-~-Subscribe topics1248 +--Subscribe topics 1038 1038 1039 1039 local Subscribe_RE_TOPIC1 = string.format('TEST') 1040 1040 1041 - ~-~-variable1252 +--variable 1042 1042 1043 1043 local last_time = 0 1044 1044 1045 - ~-~-Timing main function1256 +--Timing main function 1046 1046 1047 1047 function aws.main() 1048 1048 1049 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start") 1260 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start") 1050 1050 1051 - if g_mq then 1262 + if g_mq then 1052 1052 1053 - if g_mq:isconnected() then 1264 + if g_mq:isconnected() then 1054 1054 1055 - send_Data() 1266 + send_Data() 1056 1056 1057 - else 1268 + else 1058 1058 1059 - if os.time() - last_time > 5 then 1270 + if os.time() - last_time > 5 then 1060 1060 1061 - last_time = os.time() 1272 + last_time = os.time() 1062 1062 1063 - mymqtt_connect() 1274 + mymqtt_connect() 1064 1064 1276 + end 1277 + 1065 1065 end 1066 1066 1067 - e nd1280 + else 1068 1068 1069 - else1282 + mymqtt_init() 1070 1070 1071 - mymqtt_init()1284 + end 1072 1072 1073 - end 1286 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end") 1074 1074 1075 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end") 1076 - 1077 1077 end 1078 1078 1079 1079 1080 -~-~- Initialize MQTT 1081 1081 1292 +-- Initialize MQTT 1293 + 1082 1082 function mymqtt_init() 1083 1083 1084 - sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID)) 1296 + sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID)) 1085 1085 1086 - g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable1298 + g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) -- Create the object and declare it as a global variable 1087 1087 1088 - if g_mq then 1300 + if g_mq then 1089 1089 1090 - g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks1302 + g_mq:on("message", mymqtt_msg_callback) -- Register to receive message callbacks 1091 1091 1092 - sprint("mqtt init success") 1304 + sprint("mqtt init success") 1093 1093 1094 - else 1306 + else 1095 1095 1096 - sprint("mqtt init failed:", err) 1308 + sprint("mqtt init failed:", err) 1097 1097 1098 - end 1310 + end 1099 1099 1100 1100 end 1101 1101 1102 - ~-~- Connect to MQTT server1314 +-- Connect to MQTT server 1103 1103 1104 1104 function mymqtt_connect() 1105 1105 1106 - sprint("mqtt connecting...") 1318 + sprint("mqtt connecting...") 1107 1107 1108 - local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART) 1320 + local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART) 1109 1109 1110 - if stat == nil then 1322 + if stat == nil then 1111 1111 1112 - sprint("mqtt connect failed:", err) 1324 + sprint("mqtt connect failed:", err) 1113 1113 1114 - return 1326 + return 1115 1115 1116 - else 1328 + else 1117 1117 1118 - sprint("mqtt connected") 1330 + sprint("mqtt connected") 1119 1119 1120 - end 1332 + end 1121 1121 1122 - g_mq:subscribe(TEST, 0) 1334 + g_mq:subscribe(TEST, 0) 1123 1123 1124 1124 end 1125 1125 1126 - ~-~- Receive MQTT message callback function1338 +-- Receive MQTT message callback function 1127 1127 1128 1128 function mymqtt_msg_callback(topic, msg) 1129 1129 1130 - print("topic:",topic) 1342 + print("topic:",topic) 1131 1131 1132 - print("revdata:",msg) 1344 + print("revdata:",msg) 1133 1133 1134 - local revData = json.decode(msg) 1346 + local revData = json.decode(msg) 1135 1135 1136 - print (revData) 1348 + print (revData) 1137 1137 1138 - if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud1350 + if topic == Subscribe_RE_TOPIC1 then --Process topic information subscribed from the cloud 1139 1139 1140 -if string.match(topic,Subscribe_RE_TOPIC1) then 1352 + if string.match(topic,Subscribe_RE_TOPIC1) then 1141 1141 1142 - ~-~-if revData ~~= nil then1354 + --if revData ~= nil then 1143 1143 1144 - for k,v in pairs (revData) do 1356 + for k,v in pairs (revData) do 1145 1145 1146 - print("printing revdata after kv here") 1358 + print("printing revdata after kv here") 1147 1147 1148 - print (k,v) 1360 + print (k,v) 1149 1149 1150 - end 1362 + end 1151 1151 1152 - print ("current state is",fanstate) 1364 + print ("current state is",fanstate) 1153 1153 1154 - ~-~-end1366 + --end 1155 1155 1156 -end 1368 + end 1157 1157 1158 -end 1370 + end 1159 1159 1160 1160 end 1161 1161 1162 1162 1163 -~-~-Get real-time data 1164 1164 1376 +--Get real-time data 1377 + 1165 1165 function getData() 1166 1166 1167 - local jdata = {} 1380 + local jdata = {} 1168 1168 1169 - local addr = bns_get_alldata() 1382 + local addr = bns_get_alldata() 1170 1170 1171 - print(json.encode(addr)) 1384 + print(json.encode(addr)) 1172 1172 1173 - for i,v in pairs(addr) do 1386 + for i,v in pairs(addr) do 1174 1174 1175 - if v[2] == 1 then 1388 + if v[2] == 1 then 1176 1176 1177 - jdata[v[3]] = v[4] 1390 + jdata[v[3]] = v[4] 1178 1178 1179 - end 1392 + end 1180 1180 1181 - end 1394 + end 1182 1182 1183 - return jdata 1396 + return jdata 1184 1184 1185 1185 end 1186 1186 1187 - ~-~-send data1400 +--send data 1188 1188 1189 1189 function send_Data() 1190 1190 1191 - local pub_data = 1404 + local pub_data = 1405 + { 1406 + 123 1407 + } 1192 1192 1193 - { 1194 - 1195 -123 1196 - 1197 -} 1198 - 1199 1199 sprint(json.encode(pub_data)) 1200 1200 1201 1201 print("..........",pub_RE_TOPIC) 1202 1202 1203 - return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0) 1413 + return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0) 1204 1204 1205 1205 end 1416 +{{/code}} 1206 1206 1207 1207 Get message in AWS 1208 1208
- InputHTTPparameter.png
-
- Author
-
... ... @@ -1,0 +1,1 @@ 1 +XWiki.Hunter - Size
-
... ... @@ -1,0 +1,1 @@ 1 +17.9 KB - Content