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 ... ... @@ -224,10 +224,6 @@ 224 224 225 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 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 231 {{code language="Lua"}} 232 232 local tempBit = 0 233 233 local tempWord = 0 ... ... @@ -236,8 +236,8 @@ 236 236 local json = require("json") 237 237 local ltn12 = require("ltn12") 238 238 239 -local SID = 'AC1703bd710ffa98006d2bcc0b ********'240 -local Token = 'd3c11897623c39e538b20263ec19 ****'229 +local SID = 'AC1703bd710ffa98006d2bcc0b8d6ca63a' 230 +local Token = 'd3c11897623c39e538b20263ec190ae0' 241 241 242 242 local twilioPhoneNumber = '+14155238886' 243 243 local receiverPhoneNumber = '+8615880018277' ... ... @@ -349,104 +349,6 @@ 349 349 end 350 350 {{/code}} 351 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. ... ... @@ -465,9 +465,8 @@ 465 465 466 466 (% class="mark" %)2.If your server requires SSL certificate to log in,please use OpenCloud.Because only OpenCloud platform can support to upload certificate 467 467 468 - {{info}}360 +(% class="wikigeneratedid" %) 469 469 **✎Note: **Before program the script of MQTT, please make sure the server(MQTT broker) can be connected through MQTT Client tool. 470 -{{/info}} 471 471 472 472 (% class="wikigeneratedid" %) 473 473 Tool link: **[[MQTT.fx>>http://mqttfx.jensd.de/index.php/download]]** ... ... @@ -515,13 +515,9 @@ 515 515 --initialize mqtt 516 516 function mqtt_init() 517 517 print(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENT_ID)) 518 - if g_mq then 519 - mqtt.close() --Close mqtt object 520 - end 521 521 g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENT_ID) -- create mqtt object,and declare it as a global variable 522 522 if g_mq then 523 523 g_mq:on("message", mqtt_msg_callback) -- Register a callback for receiving messages 524 - g_mq:on("offline", mqtt_msg_offline) -- Register a callback for offline 525 525 print("mqtt init success") 526 526 else 527 527 print("mqtt init failed:", err) ... ... @@ -541,11 +541,6 @@ 541 541 g_mq:subscribe(SUBSCRIBE_TOPIC, 0) 542 542 end 543 543 544 ---Offline callback function 545 -function mqtt_msg_offline(cause) 546 - print("mqtt offline, cause:", cause) 547 -end 548 - 549 549 -- Received message callback function 550 550 function mqtt_msg_callback(topic, msg) 551 551 print("topic:", topic) ... ... @@ -584,11 +584,9 @@ 584 584 if g_mq:isconnected() then 585 585 send_data() 586 586 else 587 - --if exceed 5sec not connect, reconnect once588 - if os.time() - LAST_TIME > 5then469 + --if exceed 20 sec not connect, reconnect once 470 + if os.time() - LAST_TIME > 20 then 589 589 LAST_TIME = os.time() 590 - --reinitial the mqtt object 591 - mqtt_init() 592 592 --connect to mqtt or reconnect 593 593 mqtt_connect() 594 594 end ... ... @@ -611,134 +611,142 @@ 611 611 -- Meta class 612 612 --main 613 613 function mq.main() 614 - 615 - 494 + if not mq.m then 495 + local err = "" 616 616 617 - mq.m, err = mqtt.create("tcp://grouprobotinfo.com:1883", "ClienID") -- create connection 618 - if mq.m then 619 - mq.config = { 620 - username = "",-- ID 621 - password = "",-- password 622 - netway = 1, -- Ethernet connection, WIFI=1 623 - -- keepalive = 100, -- Optional, set the connection heartbeat interval for 100 seconds. 624 - -- cleansession = 0, -- Optional, keep session 625 - } 626 - mq.m:on("message", function(topic, msg) -- Register for receiving message callbacks 627 - local str = string.format("%s:%s", topic, msg) 628 - -- print("mqtt msg:", str) -- Print out the received topics and content 629 - end) 630 - mq.m:on("offline", function (cause) -- Register for lost connection callbacks 631 - -- addr_setstring("@xxx", "cause"..(cause or " got nil")) 632 - end) 633 - mq.m:on("arrived", function() -- Registration for sending messages to callbacks 634 - print("msg arrived") 635 - end) 636 - else 637 - print("mqtt create failed:", err) -- Create object failed 638 - end 639 - else 640 - if mq.m:isconnected() then -- If online, post a message 641 - local phaseStatus ="unknow" 642 - if addr_getbit("@Standby")== 1 then 643 - phaseStatus = "Standby" 644 - elseif addr_getbit("@Pre-Freeze")==1 then 645 - phaseStatus= "Pre-Freeze" 646 - elseif addr_getbit("@Prepare")==1 then 647 - phaseStatus ="Prepare" 648 - elseif addr_getbit("@Primary Dry")==1 then 649 - phaseStatus = "Primary dry" 650 - elseif addr_getbit("@Secondary Dry")==1 then 651 - phaseStatus = "Secondary Dry" 652 - end 653 - --print(addr_getbit("@Primary Dry")) 497 + mq.m, err = mqtt.create("tcp://grouprobotinfo.com:1883", "ClienID") -- create connection 498 + if mq.m then 499 + mq.config = { 500 + username = "",-- ID 501 + password = "",-- password 502 + netway = 1, -- Ethernet connection, WIFI=1 503 + -- keepalive = 100, -- Optional, set the connection heartbeat interval for 100 seconds. 504 + -- cleansession = 0, -- Optional, keep session 505 + } 506 + mq.m:on("message", function(topic, msg) -- Register for receiving message callbacks 507 + local str = string.format("%s:%s", topic, msg) 508 + -- print("mqtt msg:", str) -- Print out the received topics and content 509 + end 510 + ) 511 + mq.m:on("offline", function (cause) -- Register for lost connection callbacks 512 + -- addr_setstring("@xxx", "cause"..(cause or " got nil")) 513 + end) 514 + mq.m:on("arrived", function() -- Registration for sending messages to callbacks 515 + print("msg arrived") 516 + end) 517 + else 518 + print("mqtt create failed:", err) -- Create object failed 519 + end 520 + else 521 + if mq.m:isconnected() then -- If online, post a message 522 + local phaseStatus ="unknow" 523 + if addr_getbit("@Standby")== 1 then 524 + phaseStatus = "Standby" 525 + elseif addr_getbit("@Pre-Freeze")==1 then 526 + phaseStatus= "Pre-Freeze" 527 + elseif addr_getbit("@Prepare")==1 then 528 + phaseStatus ="Prepare" 529 + elseif addr_getbit("@Primary Dry")==1 then 530 + phaseStatus = "Primary dry" 531 + elseif addr_getbit("@Secondary Dry")==1 then 532 + phaseStatus = "Secondary Dry" 533 + end 534 +-- print(addr_getbit("@Primary Dry")) 654 654 ------------------------------------------------------------------------------------------------------------------------- 655 - local activating ="unknow" 656 - if addr_getbit("@Compressor")==1 then 657 - activating = ",".."Compressor" 658 - end 659 - if addr_getbit("@Silicone Pump")==1 then 660 - activating = activating..",".."Silicone Pump" 661 - end 662 - if addr_getbit("@Vacuum Pump")==1 then 663 - activating = activating..",".."Vacuum Pump" 664 - end 665 - if addr_getbit("@Root Pump")==1 then 666 - activating = activating..",".."Root Pump" 667 - end 668 - if addr_getbit("@Heater")==1 then 669 - activating = activating..",".."Heater" 670 - end 671 - if addr_getbit("@Valve Silicone")==1 then 672 - activating = activating..",".."Valve Silicone" 673 - end 674 - if addr_getbit("@Valve Ice Condenser")==1 then 675 - activating = activating..",".."Valve Ice Condenser" 676 - end 677 - if addr_getbit("@Valve Vacuum Pump")==1 then 678 - activating = activating..",".."Valve Vacuum Pump" 679 - end 680 - local pr_activating =string.sub(activating,2) 681 - -- print(pr_activating) 682 - local status_text ="unknow" 683 - if addr_getbit("@Status Run")==1 then 684 - status_text = "RUNNING" 685 - else 686 - status_text = "STOP" 687 - end 688 -------------------------------------------------------------------------------------------------------------------------- 689 - local js = {type="status", 690 - mc_name ="FD300", 691 - status=status_text, 692 - elapsed_time={ 693 - hour=addr_getword("@Elapsed Time (Hour)"), 694 - min=addr_getword("@Elapsed Time (Minute)"), 695 - sec=addr_getword("@Elapsed Time (Second)") 696 - }, 697 - phase = phaseStatus, 698 - step = addr_getword("@Step"), 699 - activating_output = pr_activating, 700 - sv=addr_getshort("@SV Silicone")/10, 701 - pv=addr_getshort("@PV Silicone")/10, 702 - product1=addr_getshort("@Product 1")/10, 536 + local activating ="unknow" 537 + if addr_getbit("@Compressor")==1 then 538 + activating = ",".."Compressor" 539 + end 540 + if addr_getbit("@Silicone Pump")==1 then 541 + activating = activating..",".."Silicone Pump" 542 + end 543 + if addr_getbit("@Vacuum Pump")==1 then 544 + activating = activating..",".."Vacuum Pump" 545 + end 546 + if addr_getbit("@Root Pump")==1 then 547 + activating = activating..",".."Root Pump" 548 + end 549 + if addr_getbit("@Heater")==1 then 550 + activating = activating..",".."Heater" 551 + end 552 + if addr_getbit("@Valve Silicone")==1 then 553 + activating = activating..",".."Valve Silicone" 554 + end 555 + if addr_getbit("@Valve Ice Condenser")==1 then 556 + activating = activating..",".."Valve Ice Condenser" 557 + end 558 + if addr_getbit("@Valve Vacuum Pump")==1 then 559 + activating = activating..",".."Valve Vacuum Pump" 560 + end 561 + local pr_activating =string.sub(activating,2) 562 + -- print(pr_activating) 703 703 704 - product2=addr_getshort("@Product 2")/10, 705 - product3=addr_getshort("@Product 3")/10, 706 - product4=addr_getshort("@Product 4")/10, 707 - ice1=addr_getshort("@Ice condenser 1")/10, 708 - ice2=addr_getshort("@Ice condenser 2")/10, 709 - vacuum=addr_getfloat("@Vacuum") 710 - } 711 - local jsAlarm = { HPC = addr_getbit("@B_25395#W0.00"), 712 - ODPC = addr_getbit("@B_25395#W0.01"), 713 - MTPC=addr_getbit("@B_25395#W0.02"), 714 - HTT = addr_getbit("@B_25395#W1.03"), 715 - CPC = addr_getbit("@B_25395#W0.08"), 716 - CPSP =addr_getbit("@B_25395#W1.00"), 717 - CPVP =addr_getbit("@B_25395#W0.10"), 718 - CPRP =addr_getbit("@B_25395#W0.11"), 719 - HP =addr_getbit("@B_25395#W1.01"), 720 - PP= addr_getbit("@B_25395#W1.02"), 721 - PO=addr_getbit("@B_25395#W0.07"), 722 - FSE=addr_getbit("@B_25395#W2.04"), 723 - AVVSVV=addr_getbit("@B_25395#W1.12"), 724 - ICHT=addr_getbit("@B_25395#W3.06") 725 - } 726 - -- ("@B_25395#CIO1.02") 727 - mq.m:publish("mqtt-v-box-epsilon-fd300", json.encode(js) , 0, 0) 728 - mq.m:publish("mqtt-v-box-epsilon-alarm-fd300", json.encode(jsAlarm) , 0, 0) 729 - else 730 - local stat, err = mq.m:connect(mq.config) -- connection 731 - if stat == nil then --Determine whether to connect 732 - print("mqtt connect failed:", err) 733 - return -- Connection failed, return directly 734 - end 735 - mq.m:subscribe("mqtt-v-box-epsilon", 0)-- Subscribe to topics 736 736 737 - end 738 - -- mq.m:unsubscribe("stc/test") 739 - -- mq.m:disconnect() -- close matt 740 - -- mq.m:close() -- close clase 741 - end 565 + 566 + local status_text ="unknow" 567 + if addr_getbit("@Status Run")==1 then 568 + status_text = "RUNNING" 569 + else 570 + status_text = "STOP" 571 + end 572 +------------------------------------------------------------------------------------------------------------------------- 573 + 574 + local js = {type="status", 575 + mc_name ="FD300", 576 + status=status_text, 577 + elapsed_time={ 578 + hour=addr_getword("@Elapsed Time (Hour)"), 579 + min=addr_getword("@Elapsed Time (Minute)"), 580 + sec=addr_getword("@Elapsed Time (Second)") 581 + }, 582 + phase = phaseStatus, 583 + step = addr_getword("@Step"), 584 + activating_output = pr_activating, 585 + sv=addr_getshort("@SV Silicone")/10, 586 + pv=addr_getshort("@PV Silicone")/10, 587 + product1=addr_getshort("@Product 1")/10, 588 + 589 + product2=addr_getshort("@Product 2")/10, 590 + product3=addr_getshort("@Product 3")/10, 591 + product4=addr_getshort("@Product 4")/10, 592 + ice1=addr_getshort("@Ice condenser 1")/10, 593 + ice2=addr_getshort("@Ice condenser 2")/10, 594 + vacuum=addr_getfloat("@Vacuum") 595 + 596 + } 597 + local jsAlarm = { HPC = addr_getbit("@B_25395#W0.00"), 598 + ODPC = addr_getbit("@B_25395#W0.01"), 599 + MTPC=addr_getbit("@B_25395#W0.02"), 600 + HTT = addr_getbit("@B_25395#W1.03"), 601 + CPC = addr_getbit("@B_25395#W0.08"), 602 + CPSP =addr_getbit("@B_25395#W1.00"), 603 + CPVP =addr_getbit("@B_25395#W0.10"), 604 + CPRP =addr_getbit("@B_25395#W0.11"), 605 + HP =addr_getbit("@B_25395#W1.01"), 606 + PP= addr_getbit("@B_25395#W1.02"), 607 + PO=addr_getbit("@B_25395#W0.07"), 608 + FSE=addr_getbit("@B_25395#W2.04"), 609 + AVVSVV=addr_getbit("@B_25395#W1.12"), 610 + ICHT=addr_getbit("@B_25395#W3.06") 611 + 612 + } 613 + 614 + -- ("@B_25395#CIO1.02") 615 + mq.m:publish("mqtt-v-box-epsilon-fd300", json.encode(js) , 0, 0) 616 + mq.m:publish("mqtt-v-box-epsilon-alarm-fd300", json.encode(jsAlarm) , 0, 0) 617 + else 618 + local stat, err = mq.m:connect(mq.config) -- connection 619 + if stat == nil then --Determine whether to connect 620 + print("mqtt connect failed:", err) 621 + return -- Connection failed, return directly 622 + end 623 + mq.m:subscribe("mqtt-v-box-epsilon", 0)-- Subscribe to topics 624 + 625 + end 626 + -- mq.m:unsubscribe("stc/test") 627 + -- mq.m:disconnect() -- close matt 628 + -- mq.m:close() -- close clase 629 + end 742 742 end 743 743 {{/code}} 744 744 ... ... @@ -1168,20 +1168,35 @@ 1168 1168 1169 1169 {{code language="java"}} 1170 1170 { 1059 + 1171 1171 "Version": "2012-10-17", 1061 + 1172 1172 "Statement": [ 1063 + 1173 1173 { 1065 + 1174 1174 "Effect": "Allow", 1067 + 1175 1175 "Action": [ 1069 + 1176 1176 "iot:Connect", 1071 + 1177 1177 "iot:Publish", 1073 + 1178 1178 "iot:Subscribe", 1075 + 1179 1179 "iot:Receive", 1077 + 1180 1180 "greengrass:Discover" 1079 + 1181 1181 ], 1081 + 1182 1182 "Resource": "*" 1083 + 1183 1183 } 1085 + 1184 1184 ] 1087 + 1185 1185 } 1186 1186 {{/code}} 1187 1187 ... ... @@ -1246,190 +1246,185 @@ 1246 1246 1247 1247 [[image:image-20220709165402-20.png]] 1248 1248 1249 -{{info}} 1250 -**✎Note:** Before using the following demo script, please make sure the V-Box firmware is newer than 22110701 1251 -{{/info}} 1252 - 1253 -{{code language="lua"}} 1254 1254 sprint = print 1255 1255 1256 ---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) 1154 +~-~-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) 1257 1257 1258 1258 local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg() 1259 1259 1260 ---publish to topics 1158 +~-~-publish to topics 1261 1261 1262 1262 local pub_RE_TOPIC = string.format('TEST') 1263 1263 1264 ---Subscribe topics 1162 +~-~-Subscribe topics 1265 1265 1266 1266 local Subscribe_RE_TOPIC1 = string.format('TEST') 1267 1267 1268 ---variable 1166 +~-~-variable 1269 1269 1270 1270 local last_time = 0 1271 1271 1272 ---Timing main function 1170 +~-~-Timing main function 1273 1273 1274 1274 function aws.main() 1275 1275 1276 - 1174 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start") 1277 1277 1278 - 1176 + if g_mq then 1279 1279 1280 - 1178 + if g_mq:isconnected() then 1281 1281 1282 - 1180 + send_Data() 1283 1283 1284 - 1182 + else 1285 1285 1286 - 1184 + if os.time() - last_time > 5 then 1287 1287 1288 - 1186 + last_time = os.time() 1289 1289 1290 - 1188 + mymqtt_connect() 1291 1291 1292 - end 1293 - 1294 1294 end 1295 1295 1296 - lse1192 + end 1297 1297 1298 - mymqtt_init()1194 + else 1299 1299 1300 - end1196 + mymqtt_init() 1301 1301 1302 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.mainend")1198 + end 1303 1303 1200 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end") 1201 + 1304 1304 end 1305 1305 1306 1306 1205 +~-~- Initialize MQTT 1307 1307 1308 --- Initialize MQTT 1309 - 1310 1310 function mymqtt_init() 1311 1311 1312 - 1209 + sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID)) 1313 1313 1314 - , 1) -- Create the object and declare it as a global variable, 1 means using the domain to connect1211 + g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable 1315 1315 1316 - 1213 + if g_mq then 1317 1317 1318 - 1215 + g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks 1319 1319 1320 - 1217 + sprint("mqtt init success") 1321 1321 1322 - 1219 + else 1323 1323 1324 - 1221 + sprint("mqtt init failed:", err) 1325 1325 1326 - 1223 + end 1327 1327 1328 1328 end 1329 1329 1330 --- Connect to MQTT server 1227 +~-~- Connect to MQTT server 1331 1331 1332 1332 function mymqtt_connect() 1333 1333 1334 - 1231 + sprint("mqtt connecting...") 1335 1335 1336 - 1233 + local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART) 1337 1337 1338 - 1235 + if stat == nil then 1339 1339 1340 - 1237 + sprint("mqtt connect failed:", err) 1341 1341 1342 - 1239 + return 1343 1343 1344 - 1241 + else 1345 1345 1346 - 1243 + sprint("mqtt connected") 1347 1347 1348 - 1245 + end 1349 1349 1350 - Subscribe_RE_TOPIC1, 0)1247 + g_mq:subscribe(TEST, 0) 1351 1351 1352 1352 end 1353 1353 1354 --- Receive MQTT message callback function 1251 +~-~- Receive MQTT message callback function 1355 1355 1356 1356 function mymqtt_msg_callback(topic, msg) 1357 1357 1358 - 1255 + print("topic:",topic) 1359 1359 1360 - 1257 + print("revdata:",msg) 1361 1361 1362 - 1259 + local revData = json.decode(msg) 1363 1363 1364 - 1261 + print (revData) 1365 1365 1366 - 1263 + if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud 1367 1367 1368 - 1265 +if string.match(topic,Subscribe_RE_TOPIC1) then 1369 1369 1370 - 1267 + ~-~-if revData ~~= nil then 1371 1371 1372 - 1269 + for k,v in pairs (revData) do 1373 1373 1374 - 1271 + print("printing revdata after kv here") 1375 1375 1376 - 1273 + print (k,v) 1377 1377 1378 - 1275 + end 1379 1379 1380 - 1277 + print ("current state is",fanstate) 1381 1381 1382 - 1279 + ~-~-end 1383 1383 1384 - 1281 +end 1385 1385 1386 - 1283 +end 1387 1387 1388 1388 end 1389 1389 1390 1390 1288 +~-~-Get real-time data 1391 1391 1392 ---Get real-time data 1393 - 1394 1394 function getData() 1395 1395 1396 - 1292 + local jdata = {} 1397 1397 1398 - 1294 + local addr = bns_get_alldata() 1399 1399 1400 - 1296 + print(json.encode(addr)) 1401 1401 1402 - 1298 + for i,v in pairs(addr) do 1403 1403 1404 - 1300 + if v[2] == 1 then 1405 1405 1406 - 1302 + jdata[v[3]] = v[4] 1407 1407 1408 - 1304 + end 1409 1409 1410 - 1306 + end 1411 1411 1412 - 1308 + return jdata 1413 1413 1414 1414 end 1415 1415 1416 ---send data 1312 +~-~-send data 1417 1417 1418 1418 function send_Data() 1419 1419 1420 - local pub_data = 1421 - { 1422 - 123 1423 - } 1316 + local pub_data = 1424 1424 1318 + { 1319 + 1320 +123 1321 + 1322 +} 1323 + 1425 1425 sprint(json.encode(pub_data)) 1426 1426 1427 1427 print("..........",pub_RE_TOPIC) 1428 1428 1429 - 1328 + return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0) 1430 1430 1431 1431 end 1432 -{{/code}} 1433 1433 1434 1434 Get message in AWS 1435 1435
- InputHTTPparameter.png
-
- Author
-
... ... @@ -1,1 +1,0 @@ 1 -XWiki.Hunter - Size
-
... ... @@ -1,1 +1,0 @@ 1 -17.9 KB - Content