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
-
... ... @@ -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}}370 +(% 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]]** ... ... @@ -474,25 +474,6 @@ 474 474 475 475 == **2.1 V-Box connect with test server(General Example)** == 476 476 477 -The following example is trying to publish to the topic "testtopic/test/no1/7890", and subscribe the topic "testtopic/test/no1/123456". 478 - 479 -And the JSON message is like follows: 480 - 481 -{{code language="JSON"}} 482 -{ 483 - "timestamp": 1631152760, 484 - "messageId": 1, 485 - "event": "test_data", 486 - "mfrs": "HMI/box", 487 - "data": 488 - { 489 - "id" : 1436217747670454274, 490 - "waterlevel" : 48, 491 - "temperture" : 23 492 - } 493 -} 494 -{{/code}} 495 - 496 496 {{code language="lua"}} 497 497 --MQTT configuration table 498 498 local MQTT_CFG={} ... ... @@ -534,13 +534,9 @@ 534 534 --initialize mqtt 535 535 function mqtt_init() 536 536 print(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENT_ID)) 537 - if g_mq then 538 - mqtt.close() --Close mqtt object 539 - end 540 540 g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENT_ID) -- create mqtt object,and declare it as a global variable 541 541 if g_mq then 542 542 g_mq:on("message", mqtt_msg_callback) -- Register a callback for receiving messages 543 - g_mq:on("offline", mqtt_msg_offline) -- Register a callback for offline 544 544 print("mqtt init success") 545 545 else 546 546 print("mqtt init failed:", err) ... ... @@ -560,11 +560,6 @@ 560 560 g_mq:subscribe(SUBSCRIBE_TOPIC, 0) 561 561 end 562 562 563 ---Offline callback function 564 -function mqtt_msg_offline(cause) 565 - print("mqtt offline, cause:", cause) 566 -end 567 - 568 568 -- Received message callback function 569 569 function mqtt_msg_callback(topic, msg) 570 570 print("topic:", topic) ... ... @@ -603,11 +603,9 @@ 603 603 if g_mq:isconnected() then 604 604 send_data() 605 605 else 606 - --if exceed 5sec not connect, reconnect once607 - if os.time() - LAST_TIME > 5then479 + --if exceed 20 sec not connect, reconnect once 480 + if os.time() - LAST_TIME > 20 then 608 608 LAST_TIME = os.time() 609 - --reinitial the mqtt object 610 - mqtt_init() 611 611 --connect to mqtt or reconnect 612 612 mqtt_connect() 613 613 end ... ... @@ -630,134 +630,142 @@ 630 630 -- Meta class 631 631 --main 632 632 function mq.main() 633 - 634 - 504 + if not mq.m then 505 + local err = "" 635 635 636 - mq.m, err = mqtt.create("tcp://grouprobotinfo.com:1883", "ClienID") -- create connection 637 - if mq.m then 638 - mq.config = { 639 - username = "",-- ID 640 - password = "",-- password 641 - netway = 1, -- Ethernet connection, WIFI=1 642 - -- keepalive = 100, -- Optional, set the connection heartbeat interval for 100 seconds. 643 - -- cleansession = 0, -- Optional, keep session 644 - } 645 - mq.m:on("message", function(topic, msg) -- Register for receiving message callbacks 646 - local str = string.format("%s:%s", topic, msg) 647 - -- print("mqtt msg:", str) -- Print out the received topics and content 648 - end) 649 - mq.m:on("offline", function (cause) -- Register for lost connection callbacks 650 - -- addr_setstring("@xxx", "cause"..(cause or " got nil")) 651 - end) 652 - mq.m:on("arrived", function() -- Registration for sending messages to callbacks 653 - print("msg arrived") 654 - end) 655 - else 656 - print("mqtt create failed:", err) -- Create object failed 657 - end 658 - else 659 - if mq.m:isconnected() then -- If online, post a message 660 - local phaseStatus ="unknow" 661 - if addr_getbit("@Standby")== 1 then 662 - phaseStatus = "Standby" 663 - elseif addr_getbit("@Pre-Freeze")==1 then 664 - phaseStatus= "Pre-Freeze" 665 - elseif addr_getbit("@Prepare")==1 then 666 - phaseStatus ="Prepare" 667 - elseif addr_getbit("@Primary Dry")==1 then 668 - phaseStatus = "Primary dry" 669 - elseif addr_getbit("@Secondary Dry")==1 then 670 - phaseStatus = "Secondary Dry" 671 - end 672 - --print(addr_getbit("@Primary Dry")) 507 + mq.m, err = mqtt.create("tcp://grouprobotinfo.com:1883", "ClienID") -- create connection 508 + if mq.m then 509 + mq.config = { 510 + username = "",-- ID 511 + password = "",-- password 512 + netway = 1, -- Ethernet connection, WIFI=1 513 + -- keepalive = 100, -- Optional, set the connection heartbeat interval for 100 seconds. 514 + -- cleansession = 0, -- Optional, keep session 515 + } 516 + mq.m:on("message", function(topic, msg) -- Register for receiving message callbacks 517 + local str = string.format("%s:%s", topic, msg) 518 + -- print("mqtt msg:", str) -- Print out the received topics and content 519 + end 520 + ) 521 + mq.m:on("offline", function (cause) -- Register for lost connection callbacks 522 + -- addr_setstring("@xxx", "cause"..(cause or " got nil")) 523 + end) 524 + mq.m:on("arrived", function() -- Registration for sending messages to callbacks 525 + print("msg arrived") 526 + end) 527 + else 528 + print("mqtt create failed:", err) -- Create object failed 529 + end 530 + else 531 + if mq.m:isconnected() then -- If online, post a message 532 + local phaseStatus ="unknow" 533 + if addr_getbit("@Standby")== 1 then 534 + phaseStatus = "Standby" 535 + elseif addr_getbit("@Pre-Freeze")==1 then 536 + phaseStatus= "Pre-Freeze" 537 + elseif addr_getbit("@Prepare")==1 then 538 + phaseStatus ="Prepare" 539 + elseif addr_getbit("@Primary Dry")==1 then 540 + phaseStatus = "Primary dry" 541 + elseif addr_getbit("@Secondary Dry")==1 then 542 + phaseStatus = "Secondary Dry" 543 + end 544 +-- print(addr_getbit("@Primary Dry")) 673 673 ------------------------------------------------------------------------------------------------------------------------- 674 - local activating ="unknow" 675 - if addr_getbit("@Compressor")==1 then 676 - activating = ",".."Compressor" 677 - end 678 - if addr_getbit("@Silicone Pump")==1 then 679 - activating = activating..",".."Silicone Pump" 680 - end 681 - if addr_getbit("@Vacuum Pump")==1 then 682 - activating = activating..",".."Vacuum Pump" 683 - end 684 - if addr_getbit("@Root Pump")==1 then 685 - activating = activating..",".."Root Pump" 686 - end 687 - if addr_getbit("@Heater")==1 then 688 - activating = activating..",".."Heater" 689 - end 690 - if addr_getbit("@Valve Silicone")==1 then 691 - activating = activating..",".."Valve Silicone" 692 - end 693 - if addr_getbit("@Valve Ice Condenser")==1 then 694 - activating = activating..",".."Valve Ice Condenser" 695 - end 696 - if addr_getbit("@Valve Vacuum Pump")==1 then 697 - activating = activating..",".."Valve Vacuum Pump" 698 - end 699 - local pr_activating =string.sub(activating,2) 700 - -- print(pr_activating) 701 - local status_text ="unknow" 702 - if addr_getbit("@Status Run")==1 then 703 - status_text = "RUNNING" 704 - else 705 - status_text = "STOP" 706 - end 707 -------------------------------------------------------------------------------------------------------------------------- 708 - local js = {type="status", 709 - mc_name ="FD300", 710 - status=status_text, 711 - elapsed_time={ 712 - hour=addr_getword("@Elapsed Time (Hour)"), 713 - min=addr_getword("@Elapsed Time (Minute)"), 714 - sec=addr_getword("@Elapsed Time (Second)") 715 - }, 716 - phase = phaseStatus, 717 - step = addr_getword("@Step"), 718 - activating_output = pr_activating, 719 - sv=addr_getshort("@SV Silicone")/10, 720 - pv=addr_getshort("@PV Silicone")/10, 721 - product1=addr_getshort("@Product 1")/10, 546 + local activating ="unknow" 547 + if addr_getbit("@Compressor")==1 then 548 + activating = ",".."Compressor" 549 + end 550 + if addr_getbit("@Silicone Pump")==1 then 551 + activating = activating..",".."Silicone Pump" 552 + end 553 + if addr_getbit("@Vacuum Pump")==1 then 554 + activating = activating..",".."Vacuum Pump" 555 + end 556 + if addr_getbit("@Root Pump")==1 then 557 + activating = activating..",".."Root Pump" 558 + end 559 + if addr_getbit("@Heater")==1 then 560 + activating = activating..",".."Heater" 561 + end 562 + if addr_getbit("@Valve Silicone")==1 then 563 + activating = activating..",".."Valve Silicone" 564 + end 565 + if addr_getbit("@Valve Ice Condenser")==1 then 566 + activating = activating..",".."Valve Ice Condenser" 567 + end 568 + if addr_getbit("@Valve Vacuum Pump")==1 then 569 + activating = activating..",".."Valve Vacuum Pump" 570 + end 571 + local pr_activating =string.sub(activating,2) 572 + -- print(pr_activating) 722 722 723 - product2=addr_getshort("@Product 2")/10, 724 - product3=addr_getshort("@Product 3")/10, 725 - product4=addr_getshort("@Product 4")/10, 726 - ice1=addr_getshort("@Ice condenser 1")/10, 727 - ice2=addr_getshort("@Ice condenser 2")/10, 728 - vacuum=addr_getfloat("@Vacuum") 729 - } 730 - local jsAlarm = { HPC = addr_getbit("@B_25395#W0.00"), 731 - ODPC = addr_getbit("@B_25395#W0.01"), 732 - MTPC=addr_getbit("@B_25395#W0.02"), 733 - HTT = addr_getbit("@B_25395#W1.03"), 734 - CPC = addr_getbit("@B_25395#W0.08"), 735 - CPSP =addr_getbit("@B_25395#W1.00"), 736 - CPVP =addr_getbit("@B_25395#W0.10"), 737 - CPRP =addr_getbit("@B_25395#W0.11"), 738 - HP =addr_getbit("@B_25395#W1.01"), 739 - PP= addr_getbit("@B_25395#W1.02"), 740 - PO=addr_getbit("@B_25395#W0.07"), 741 - FSE=addr_getbit("@B_25395#W2.04"), 742 - AVVSVV=addr_getbit("@B_25395#W1.12"), 743 - ICHT=addr_getbit("@B_25395#W3.06") 744 - } 745 - -- ("@B_25395#CIO1.02") 746 - mq.m:publish("mqtt-v-box-epsilon-fd300", json.encode(js) , 0, 0) 747 - mq.m:publish("mqtt-v-box-epsilon-alarm-fd300", json.encode(jsAlarm) , 0, 0) 748 - else 749 - local stat, err = mq.m:connect(mq.config) -- connection 750 - if stat == nil then --Determine whether to connect 751 - print("mqtt connect failed:", err) 752 - return -- Connection failed, return directly 753 - end 754 - mq.m:subscribe("mqtt-v-box-epsilon", 0)-- Subscribe to topics 755 755 756 - end 757 - -- mq.m:unsubscribe("stc/test") 758 - -- mq.m:disconnect() -- close matt 759 - -- mq.m:close() -- close clase 760 - end 575 + 576 + local status_text ="unknow" 577 + if addr_getbit("@Status Run")==1 then 578 + status_text = "RUNNING" 579 + else 580 + status_text = "STOP" 581 + end 582 +------------------------------------------------------------------------------------------------------------------------- 583 + 584 + local js = {type="status", 585 + mc_name ="FD300", 586 + status=status_text, 587 + elapsed_time={ 588 + hour=addr_getword("@Elapsed Time (Hour)"), 589 + min=addr_getword("@Elapsed Time (Minute)"), 590 + sec=addr_getword("@Elapsed Time (Second)") 591 + }, 592 + phase = phaseStatus, 593 + step = addr_getword("@Step"), 594 + activating_output = pr_activating, 595 + sv=addr_getshort("@SV Silicone")/10, 596 + pv=addr_getshort("@PV Silicone")/10, 597 + product1=addr_getshort("@Product 1")/10, 598 + 599 + product2=addr_getshort("@Product 2")/10, 600 + product3=addr_getshort("@Product 3")/10, 601 + product4=addr_getshort("@Product 4")/10, 602 + ice1=addr_getshort("@Ice condenser 1")/10, 603 + ice2=addr_getshort("@Ice condenser 2")/10, 604 + vacuum=addr_getfloat("@Vacuum") 605 + 606 + } 607 + local jsAlarm = { HPC = addr_getbit("@B_25395#W0.00"), 608 + ODPC = addr_getbit("@B_25395#W0.01"), 609 + MTPC=addr_getbit("@B_25395#W0.02"), 610 + HTT = addr_getbit("@B_25395#W1.03"), 611 + CPC = addr_getbit("@B_25395#W0.08"), 612 + CPSP =addr_getbit("@B_25395#W1.00"), 613 + CPVP =addr_getbit("@B_25395#W0.10"), 614 + CPRP =addr_getbit("@B_25395#W0.11"), 615 + HP =addr_getbit("@B_25395#W1.01"), 616 + PP= addr_getbit("@B_25395#W1.02"), 617 + PO=addr_getbit("@B_25395#W0.07"), 618 + FSE=addr_getbit("@B_25395#W2.04"), 619 + AVVSVV=addr_getbit("@B_25395#W1.12"), 620 + ICHT=addr_getbit("@B_25395#W3.06") 621 + 622 + } 623 + 624 + -- ("@B_25395#CIO1.02") 625 + mq.m:publish("mqtt-v-box-epsilon-fd300", json.encode(js) , 0, 0) 626 + mq.m:publish("mqtt-v-box-epsilon-alarm-fd300", json.encode(jsAlarm) , 0, 0) 627 + else 628 + local stat, err = mq.m:connect(mq.config) -- connection 629 + if stat == nil then --Determine whether to connect 630 + print("mqtt connect failed:", err) 631 + return -- Connection failed, return directly 632 + end 633 + mq.m:subscribe("mqtt-v-box-epsilon", 0)-- Subscribe to topics 634 + 635 + end 636 + -- mq.m:unsubscribe("stc/test") 637 + -- mq.m:disconnect() -- close matt 638 + -- mq.m:close() -- close clase 639 + end 761 761 end 762 762 {{/code}} 763 763 ... ... @@ -1187,20 +1187,35 @@ 1187 1187 1188 1188 {{code language="java"}} 1189 1189 { 1069 + 1190 1190 "Version": "2012-10-17", 1071 + 1191 1191 "Statement": [ 1073 + 1192 1192 { 1075 + 1193 1193 "Effect": "Allow", 1077 + 1194 1194 "Action": [ 1079 + 1195 1195 "iot:Connect", 1081 + 1196 1196 "iot:Publish", 1083 + 1197 1197 "iot:Subscribe", 1085 + 1198 1198 "iot:Receive", 1087 + 1199 1199 "greengrass:Discover" 1089 + 1200 1200 ], 1091 + 1201 1201 "Resource": "*" 1093 + 1202 1202 } 1095 + 1203 1203 ] 1097 + 1204 1204 } 1205 1205 {{/code}} 1206 1206 ... ... @@ -1265,190 +1265,185 @@ 1265 1265 1266 1266 [[image:image-20220709165402-20.png]] 1267 1267 1268 -{{info}} 1269 -**✎Note:** Before using the following demo script, please make sure the V-Box firmware is newer than 22110701 1270 -{{/info}} 1271 - 1272 -{{code language="lua"}} 1273 1273 sprint = print 1274 1274 1275 ---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) 1164 +~-~-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) 1276 1276 1277 1277 local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg() 1278 1278 1279 ---publish to topics 1168 +~-~-publish to topics 1280 1280 1281 1281 local pub_RE_TOPIC = string.format('TEST') 1282 1282 1283 ---Subscribe topics 1172 +~-~-Subscribe topics 1284 1284 1285 1285 local Subscribe_RE_TOPIC1 = string.format('TEST') 1286 1286 1287 ---variable 1176 +~-~-variable 1288 1288 1289 1289 local last_time = 0 1290 1290 1291 ---Timing main function 1180 +~-~-Timing main function 1292 1292 1293 1293 function aws.main() 1294 1294 1295 - 1184 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start") 1296 1296 1297 - 1186 + if g_mq then 1298 1298 1299 - 1188 + if g_mq:isconnected() then 1300 1300 1301 - 1190 + send_Data() 1302 1302 1303 - 1192 + else 1304 1304 1305 - 1194 + if os.time() - last_time > 5 then 1306 1306 1307 - 1196 + last_time = os.time() 1308 1308 1309 - 1198 + mymqtt_connect() 1310 1310 1311 - end 1312 - 1313 1313 end 1314 1314 1315 - lse1202 + end 1316 1316 1317 - mymqtt_init()1204 + else 1318 1318 1319 - end1206 + mymqtt_init() 1320 1320 1321 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.mainend")1208 + end 1322 1322 1210 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end") 1211 + 1323 1323 end 1324 1324 1325 1325 1215 +~-~- Initialize MQTT 1326 1326 1327 --- Initialize MQTT 1328 - 1329 1329 function mymqtt_init() 1330 1330 1331 - 1219 + sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID)) 1332 1332 1333 - , 1) -- Create the object and declare it as a global variable, 1 means using the domain to connect1221 + g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable 1334 1334 1335 - 1223 + if g_mq then 1336 1336 1337 - 1225 + g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks 1338 1338 1339 - 1227 + sprint("mqtt init success") 1340 1340 1341 - 1229 + else 1342 1342 1343 - 1231 + sprint("mqtt init failed:", err) 1344 1344 1345 - 1233 + end 1346 1346 1347 1347 end 1348 1348 1349 --- Connect to MQTT server 1237 +~-~- Connect to MQTT server 1350 1350 1351 1351 function mymqtt_connect() 1352 1352 1353 - 1241 + sprint("mqtt connecting...") 1354 1354 1355 - 1243 + local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART) 1356 1356 1357 - 1245 + if stat == nil then 1358 1358 1359 - 1247 + sprint("mqtt connect failed:", err) 1360 1360 1361 - 1249 + return 1362 1362 1363 - 1251 + else 1364 1364 1365 - 1253 + sprint("mqtt connected") 1366 1366 1367 - 1255 + end 1368 1368 1369 - Subscribe_RE_TOPIC1, 0)1257 + g_mq:subscribe(TEST, 0) 1370 1370 1371 1371 end 1372 1372 1373 --- Receive MQTT message callback function 1261 +~-~- Receive MQTT message callback function 1374 1374 1375 1375 function mymqtt_msg_callback(topic, msg) 1376 1376 1377 - 1265 + print("topic:",topic) 1378 1378 1379 - 1267 + print("revdata:",msg) 1380 1380 1381 - 1269 + local revData = json.decode(msg) 1382 1382 1383 - 1271 + print (revData) 1384 1384 1385 - 1273 + if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud 1386 1386 1387 - 1275 +if string.match(topic,Subscribe_RE_TOPIC1) then 1388 1388 1389 - 1277 + ~-~-if revData ~~= nil then 1390 1390 1391 - 1279 + for k,v in pairs (revData) do 1392 1392 1393 - 1281 + print("printing revdata after kv here") 1394 1394 1395 - 1283 + print (k,v) 1396 1396 1397 - 1285 + end 1398 1398 1399 - 1287 + print ("current state is",fanstate) 1400 1400 1401 - 1289 + ~-~-end 1402 1402 1403 - 1291 +end 1404 1404 1405 - 1293 +end 1406 1406 1407 1407 end 1408 1408 1409 1409 1298 +~-~-Get real-time data 1410 1410 1411 ---Get real-time data 1412 - 1413 1413 function getData() 1414 1414 1415 - 1302 + local jdata = {} 1416 1416 1417 - 1304 + local addr = bns_get_alldata() 1418 1418 1419 - 1306 + print(json.encode(addr)) 1420 1420 1421 - 1308 + for i,v in pairs(addr) do 1422 1422 1423 - 1310 + if v[2] == 1 then 1424 1424 1425 - 1312 + jdata[v[3]] = v[4] 1426 1426 1427 - 1314 + end 1428 1428 1429 - 1316 + end 1430 1430 1431 - 1318 + return jdata 1432 1432 1433 1433 end 1434 1434 1435 ---send data 1322 +~-~-send data 1436 1436 1437 1437 function send_Data() 1438 1438 1439 - local pub_data = 1440 - { 1441 - 123 1442 - } 1326 + local pub_data = 1443 1443 1328 + { 1329 + 1330 +123 1331 + 1332 +} 1333 + 1444 1444 sprint(json.encode(pub_data)) 1445 1445 1446 1446 print("..........",pub_RE_TOPIC) 1447 1447 1448 - 1338 + return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0) 1449 1449 1450 1450 end 1451 -{{/code}} 1452 1452 1453 1453 Get message in AWS 1454 1454
- InputHTTPparameter.png
-
- Author
-
... ... @@ -1,1 +1,0 @@ 1 -XWiki.Hunter - Size
-
... ... @@ -1,1 +1,0 @@ 1 -17.9 KB - Content