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
-
... ... @@ -145,7 +145,7 @@ 145 145 146 146 This example shows how to use the LINE Notify to send message into LINE group. When monitoring bit "@test" changes, it will trigger and send the message. Please replace with your own Token. 147 147 148 -{{code language="lua"}}148 +{{code}} 149 149 local tempBit = 0 150 150 local tempWord = 0 151 151 ... ... @@ -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 ... ... @@ -349,135 +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 -== **1.9 High-Low Byte Switch** == 451 - 452 -The following example is converting the floating number from order 1234 to order 3412, and formating output the number with 2 decimal point. About which high-low word order corresponding to which value, please refer to the [[Address Operation Table>>doc:V-BOX.V-Net.Manual.04 Lua Script.01 Lua Functions.WebHome||anchor="H2Addressoperation"]]. 453 - 454 -{{code language="lua"}} 455 -function highLowByteSwitch(floatNumber) 456 - addr_setfloat("@W_0#HDW23036",floatNumber,0,2) 457 - local newFloat = addr_getfloat("@W_0#HDW23036") 458 - local formattedFloat = string.format("%.2f",newFloat) 459 - print("The formatted float value is the : "..formattedFloat) 460 - return formattedFloat 461 -end 462 -{{/code}} 463 - 464 -== **1.10 Read 64bits Unsigned Value** == 465 - 466 -In our built-in function library doesn't have the function for reading 64-bit unsigned format value, so the following function is for solve this. But if the number is greater 2^53, the precision will be lost. So the final result will be a little bit different from the original value. 467 - 468 -{{code language="lua"}} 469 -function addr_getquatra(address) 470 - local highAddress = addr_newnoaddr(address,2) 471 - local low32 = addr_getdword(address) 472 - local high32 = addr_getdword(highAddress) 473 - --print("the low number is "..low32) 474 - --print("the high number is "..high32) 475 - local formatVal = string.format("%64.0f",2^32*high32+low32) 476 - print("the format value is ".. formatVal) 477 - return formatVal 478 -end 479 -{{/code}} 480 - 481 481 = **2 V-Box connect with third part server** = 482 482 483 483 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. ... ... @@ -496,9 +496,8 @@ 496 496 497 497 (% class="mark" %)2.If your server requires SSL certificate to log in,please use OpenCloud.Because only OpenCloud platform can support to upload certificate 498 498 499 - {{info}}366 +(% class="wikigeneratedid" %) 500 500 **✎Note: **Before program the script of MQTT, please make sure the server(MQTT broker) can be connected through MQTT Client tool. 501 -{{/info}} 502 502 503 503 (% class="wikigeneratedid" %) 504 504 Tool link: **[[MQTT.fx>>http://mqttfx.jensd.de/index.php/download]]** ... ... @@ -505,25 +505,6 @@ 505 505 506 506 == **2.1 V-Box connect with test server(General Example)** == 507 507 508 -The following example is trying to publish to the topic "testtopic/test/no1/7890", and subscribe the topic "testtopic/test/no1/123456". 509 - 510 -And the JSON message is like follows: 511 - 512 -{{code language="JSON"}} 513 -{ 514 - "timestamp": 1631152760, 515 - "messageId": 1, 516 - "event": "test_data", 517 - "mfrs": "HMI/box", 518 - "data": 519 - { 520 - "id" : 1436217747670454274, 521 - "waterlevel" : 48, 522 - "temperture" : 23 523 - } 524 -} 525 -{{/code}} 526 - 527 527 {{code language="lua"}} 528 528 --MQTT configuration table 529 529 local MQTT_CFG={} ... ... @@ -565,13 +565,9 @@ 565 565 --initialize mqtt 566 566 function mqtt_init() 567 567 print(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENT_ID)) 568 - if g_mq then 569 - mqtt.close() --Close mqtt object 570 - end 571 571 g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENT_ID) -- create mqtt object,and declare it as a global variable 572 572 if g_mq then 573 573 g_mq:on("message", mqtt_msg_callback) -- Register a callback for receiving messages 574 - g_mq:on("offline", mqtt_msg_offline) -- Register a callback for offline 575 575 print("mqtt init success") 576 576 else 577 577 print("mqtt init failed:", err) ... ... @@ -591,11 +591,6 @@ 591 591 g_mq:subscribe(SUBSCRIBE_TOPIC, 0) 592 592 end 593 593 594 ---Offline callback function 595 -function mqtt_msg_offline(cause) 596 - print("mqtt offline, cause:", cause) 597 -end 598 - 599 599 -- Received message callback function 600 600 function mqtt_msg_callback(topic, msg) 601 601 print("topic:", topic) ... ... @@ -634,11 +634,9 @@ 634 634 if g_mq:isconnected() then 635 635 send_data() 636 636 else 637 - --if exceed 5sec not connect, reconnect once638 - if os.time() - LAST_TIME > 5then475 + --if exceed 20 sec not connect, reconnect once 476 + if os.time() - LAST_TIME > 20 then 639 639 LAST_TIME = os.time() 640 - --reinitial the mqtt object 641 - mqtt_init() 642 642 --connect to mqtt or reconnect 643 643 mqtt_connect() 644 644 end ... ... @@ -661,134 +661,142 @@ 661 661 -- Meta class 662 662 --main 663 663 function mq.main() 664 - 665 - 500 + if not mq.m then 501 + local err = "" 666 666 667 - mq.m, err = mqtt.create("tcp://grouprobotinfo.com:1883", "ClienID") -- create connection 668 - if mq.m then 669 - mq.config = { 670 - username = "",-- ID 671 - password = "",-- password 672 - netway = 1, -- Ethernet connection, WIFI=1 673 - -- keepalive = 100, -- Optional, set the connection heartbeat interval for 100 seconds. 674 - -- cleansession = 0, -- Optional, keep session 675 - } 676 - mq.m:on("message", function(topic, msg) -- Register for receiving message callbacks 677 - local str = string.format("%s:%s", topic, msg) 678 - -- print("mqtt msg:", str) -- Print out the received topics and content 679 - end) 680 - mq.m:on("offline", function (cause) -- Register for lost connection callbacks 681 - -- addr_setstring("@xxx", "cause"..(cause or " got nil")) 682 - end) 683 - mq.m:on("arrived", function() -- Registration for sending messages to callbacks 684 - print("msg arrived") 685 - end) 686 - else 687 - print("mqtt create failed:", err) -- Create object failed 688 - end 689 - else 690 - if mq.m:isconnected() then -- If online, post a message 691 - local phaseStatus ="unknow" 692 - if addr_getbit("@Standby")== 1 then 693 - phaseStatus = "Standby" 694 - elseif addr_getbit("@Pre-Freeze")==1 then 695 - phaseStatus= "Pre-Freeze" 696 - elseif addr_getbit("@Prepare")==1 then 697 - phaseStatus ="Prepare" 698 - elseif addr_getbit("@Primary Dry")==1 then 699 - phaseStatus = "Primary dry" 700 - elseif addr_getbit("@Secondary Dry")==1 then 701 - phaseStatus = "Secondary Dry" 702 - end 703 - --print(addr_getbit("@Primary Dry")) 503 + mq.m, err = mqtt.create("tcp://grouprobotinfo.com:1883", "ClienID") -- create connection 504 + if mq.m then 505 + mq.config = { 506 + username = "",-- ID 507 + password = "",-- password 508 + netway = 1, -- Ethernet connection, WIFI=1 509 + -- keepalive = 100, -- Optional, set the connection heartbeat interval for 100 seconds. 510 + -- cleansession = 0, -- Optional, keep session 511 + } 512 + mq.m:on("message", function(topic, msg) -- Register for receiving message callbacks 513 + local str = string.format("%s:%s", topic, msg) 514 + -- print("mqtt msg:", str) -- Print out the received topics and content 515 + end 516 + ) 517 + mq.m:on("offline", function (cause) -- Register for lost connection callbacks 518 + -- addr_setstring("@xxx", "cause"..(cause or " got nil")) 519 + end) 520 + mq.m:on("arrived", function() -- Registration for sending messages to callbacks 521 + print("msg arrived") 522 + end) 523 + else 524 + print("mqtt create failed:", err) -- Create object failed 525 + end 526 + else 527 + if mq.m:isconnected() then -- If online, post a message 528 + local phaseStatus ="unknow" 529 + if addr_getbit("@Standby")== 1 then 530 + phaseStatus = "Standby" 531 + elseif addr_getbit("@Pre-Freeze")==1 then 532 + phaseStatus= "Pre-Freeze" 533 + elseif addr_getbit("@Prepare")==1 then 534 + phaseStatus ="Prepare" 535 + elseif addr_getbit("@Primary Dry")==1 then 536 + phaseStatus = "Primary dry" 537 + elseif addr_getbit("@Secondary Dry")==1 then 538 + phaseStatus = "Secondary Dry" 539 + end 540 +-- print(addr_getbit("@Primary Dry")) 704 704 ------------------------------------------------------------------------------------------------------------------------- 705 - local activating ="unknow" 706 - if addr_getbit("@Compressor")==1 then 707 - activating = ",".."Compressor" 708 - end 709 - if addr_getbit("@Silicone Pump")==1 then 710 - activating = activating..",".."Silicone Pump" 711 - end 712 - if addr_getbit("@Vacuum Pump")==1 then 713 - activating = activating..",".."Vacuum Pump" 714 - end 715 - if addr_getbit("@Root Pump")==1 then 716 - activating = activating..",".."Root Pump" 717 - end 718 - if addr_getbit("@Heater")==1 then 719 - activating = activating..",".."Heater" 720 - end 721 - if addr_getbit("@Valve Silicone")==1 then 722 - activating = activating..",".."Valve Silicone" 723 - end 724 - if addr_getbit("@Valve Ice Condenser")==1 then 725 - activating = activating..",".."Valve Ice Condenser" 726 - end 727 - if addr_getbit("@Valve Vacuum Pump")==1 then 728 - activating = activating..",".."Valve Vacuum Pump" 729 - end 730 - local pr_activating =string.sub(activating,2) 731 - -- print(pr_activating) 732 - local status_text ="unknow" 733 - if addr_getbit("@Status Run")==1 then 734 - status_text = "RUNNING" 735 - else 736 - status_text = "STOP" 737 - end 738 -------------------------------------------------------------------------------------------------------------------------- 739 - local js = {type="status", 740 - mc_name ="FD300", 741 - status=status_text, 742 - elapsed_time={ 743 - hour=addr_getword("@Elapsed Time (Hour)"), 744 - min=addr_getword("@Elapsed Time (Minute)"), 745 - sec=addr_getword("@Elapsed Time (Second)") 746 - }, 747 - phase = phaseStatus, 748 - step = addr_getword("@Step"), 749 - activating_output = pr_activating, 750 - sv=addr_getshort("@SV Silicone")/10, 751 - pv=addr_getshort("@PV Silicone")/10, 752 - product1=addr_getshort("@Product 1")/10, 542 + local activating ="unknow" 543 + if addr_getbit("@Compressor")==1 then 544 + activating = ",".."Compressor" 545 + end 546 + if addr_getbit("@Silicone Pump")==1 then 547 + activating = activating..",".."Silicone Pump" 548 + end 549 + if addr_getbit("@Vacuum Pump")==1 then 550 + activating = activating..",".."Vacuum Pump" 551 + end 552 + if addr_getbit("@Root Pump")==1 then 553 + activating = activating..",".."Root Pump" 554 + end 555 + if addr_getbit("@Heater")==1 then 556 + activating = activating..",".."Heater" 557 + end 558 + if addr_getbit("@Valve Silicone")==1 then 559 + activating = activating..",".."Valve Silicone" 560 + end 561 + if addr_getbit("@Valve Ice Condenser")==1 then 562 + activating = activating..",".."Valve Ice Condenser" 563 + end 564 + if addr_getbit("@Valve Vacuum Pump")==1 then 565 + activating = activating..",".."Valve Vacuum Pump" 566 + end 567 + local pr_activating =string.sub(activating,2) 568 + -- print(pr_activating) 753 753 754 - product2=addr_getshort("@Product 2")/10, 755 - product3=addr_getshort("@Product 3")/10, 756 - product4=addr_getshort("@Product 4")/10, 757 - ice1=addr_getshort("@Ice condenser 1")/10, 758 - ice2=addr_getshort("@Ice condenser 2")/10, 759 - vacuum=addr_getfloat("@Vacuum") 760 - } 761 - local jsAlarm = { HPC = addr_getbit("@B_25395#W0.00"), 762 - ODPC = addr_getbit("@B_25395#W0.01"), 763 - MTPC=addr_getbit("@B_25395#W0.02"), 764 - HTT = addr_getbit("@B_25395#W1.03"), 765 - CPC = addr_getbit("@B_25395#W0.08"), 766 - CPSP =addr_getbit("@B_25395#W1.00"), 767 - CPVP =addr_getbit("@B_25395#W0.10"), 768 - CPRP =addr_getbit("@B_25395#W0.11"), 769 - HP =addr_getbit("@B_25395#W1.01"), 770 - PP= addr_getbit("@B_25395#W1.02"), 771 - PO=addr_getbit("@B_25395#W0.07"), 772 - FSE=addr_getbit("@B_25395#W2.04"), 773 - AVVSVV=addr_getbit("@B_25395#W1.12"), 774 - ICHT=addr_getbit("@B_25395#W3.06") 775 - } 776 - -- ("@B_25395#CIO1.02") 777 - mq.m:publish("mqtt-v-box-epsilon-fd300", json.encode(js) , 0, 0) 778 - mq.m:publish("mqtt-v-box-epsilon-alarm-fd300", json.encode(jsAlarm) , 0, 0) 779 - else 780 - local stat, err = mq.m:connect(mq.config) -- connection 781 - if stat == nil then --Determine whether to connect 782 - print("mqtt connect failed:", err) 783 - return -- Connection failed, return directly 784 - end 785 - mq.m:subscribe("mqtt-v-box-epsilon", 0)-- Subscribe to topics 786 786 787 - end 788 - -- mq.m:unsubscribe("stc/test") 789 - -- mq.m:disconnect() -- close matt 790 - -- mq.m:close() -- close clase 791 - end 571 + 572 + local status_text ="unknow" 573 + if addr_getbit("@Status Run")==1 then 574 + status_text = "RUNNING" 575 + else 576 + status_text = "STOP" 577 + end 578 +------------------------------------------------------------------------------------------------------------------------- 579 + 580 + local js = {type="status", 581 + mc_name ="FD300", 582 + status=status_text, 583 + elapsed_time={ 584 + hour=addr_getword("@Elapsed Time (Hour)"), 585 + min=addr_getword("@Elapsed Time (Minute)"), 586 + sec=addr_getword("@Elapsed Time (Second)") 587 + }, 588 + phase = phaseStatus, 589 + step = addr_getword("@Step"), 590 + activating_output = pr_activating, 591 + sv=addr_getshort("@SV Silicone")/10, 592 + pv=addr_getshort("@PV Silicone")/10, 593 + product1=addr_getshort("@Product 1")/10, 594 + 595 + product2=addr_getshort("@Product 2")/10, 596 + product3=addr_getshort("@Product 3")/10, 597 + product4=addr_getshort("@Product 4")/10, 598 + ice1=addr_getshort("@Ice condenser 1")/10, 599 + ice2=addr_getshort("@Ice condenser 2")/10, 600 + vacuum=addr_getfloat("@Vacuum") 601 + 602 + } 603 + local jsAlarm = { HPC = addr_getbit("@B_25395#W0.00"), 604 + ODPC = addr_getbit("@B_25395#W0.01"), 605 + MTPC=addr_getbit("@B_25395#W0.02"), 606 + HTT = addr_getbit("@B_25395#W1.03"), 607 + CPC = addr_getbit("@B_25395#W0.08"), 608 + CPSP =addr_getbit("@B_25395#W1.00"), 609 + CPVP =addr_getbit("@B_25395#W0.10"), 610 + CPRP =addr_getbit("@B_25395#W0.11"), 611 + HP =addr_getbit("@B_25395#W1.01"), 612 + PP= addr_getbit("@B_25395#W1.02"), 613 + PO=addr_getbit("@B_25395#W0.07"), 614 + FSE=addr_getbit("@B_25395#W2.04"), 615 + AVVSVV=addr_getbit("@B_25395#W1.12"), 616 + ICHT=addr_getbit("@B_25395#W3.06") 617 + 618 + } 619 + 620 + -- ("@B_25395#CIO1.02") 621 + mq.m:publish("mqtt-v-box-epsilon-fd300", json.encode(js) , 0, 0) 622 + mq.m:publish("mqtt-v-box-epsilon-alarm-fd300", json.encode(jsAlarm) , 0, 0) 623 + else 624 + local stat, err = mq.m:connect(mq.config) -- connection 625 + if stat == nil then --Determine whether to connect 626 + print("mqtt connect failed:", err) 627 + return -- Connection failed, return directly 628 + end 629 + mq.m:subscribe("mqtt-v-box-epsilon", 0)-- Subscribe to topics 630 + 631 + end 632 + -- mq.m:unsubscribe("stc/test") 633 + -- mq.m:disconnect() -- close matt 634 + -- mq.m:close() -- close clase 635 + end 792 792 end 793 793 {{/code}} 794 794 ... ... @@ -1218,20 +1218,35 @@ 1218 1218 1219 1219 {{code language="java"}} 1220 1220 { 1065 + 1221 1221 "Version": "2012-10-17", 1067 + 1222 1222 "Statement": [ 1069 + 1223 1223 { 1071 + 1224 1224 "Effect": "Allow", 1073 + 1225 1225 "Action": [ 1075 + 1226 1226 "iot:Connect", 1077 + 1227 1227 "iot:Publish", 1079 + 1228 1228 "iot:Subscribe", 1081 + 1229 1229 "iot:Receive", 1083 + 1230 1230 "greengrass:Discover" 1085 + 1231 1231 ], 1087 + 1232 1232 "Resource": "*" 1089 + 1233 1233 } 1091 + 1234 1234 ] 1093 + 1235 1235 } 1236 1236 {{/code}} 1237 1237 ... ... @@ -1296,190 +1296,185 @@ 1296 1296 1297 1297 [[image:image-20220709165402-20.png]] 1298 1298 1299 -{{info}} 1300 -**✎Note:** Before using the following demo script, please make sure the V-Box firmware is newer than 22110701 1301 -{{/info}} 1302 - 1303 -{{code language="lua"}} 1304 1304 sprint = print 1305 1305 1306 ---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) 1160 +~-~-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) 1307 1307 1308 1308 local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg() 1309 1309 1310 ---publish to topics 1164 +~-~-publish to topics 1311 1311 1312 1312 local pub_RE_TOPIC = string.format('TEST') 1313 1313 1314 ---Subscribe topics 1168 +~-~-Subscribe topics 1315 1315 1316 1316 local Subscribe_RE_TOPIC1 = string.format('TEST') 1317 1317 1318 ---variable 1172 +~-~-variable 1319 1319 1320 1320 local last_time = 0 1321 1321 1322 ---Timing main function 1176 +~-~-Timing main function 1323 1323 1324 1324 function aws.main() 1325 1325 1326 - 1180 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start") 1327 1327 1328 - 1182 + if g_mq then 1329 1329 1330 - 1184 + if g_mq:isconnected() then 1331 1331 1332 - 1186 + send_Data() 1333 1333 1334 - 1188 + else 1335 1335 1336 - 1190 + if os.time() - last_time > 5 then 1337 1337 1338 - 1192 + last_time = os.time() 1339 1339 1340 - 1194 + mymqtt_connect() 1341 1341 1342 - end 1343 - 1344 1344 end 1345 1345 1346 - lse1198 + end 1347 1347 1348 - mymqtt_init()1200 + else 1349 1349 1350 - end1202 + mymqtt_init() 1351 1351 1352 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.mainend")1204 + end 1353 1353 1206 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end") 1207 + 1354 1354 end 1355 1355 1356 1356 1211 +~-~- Initialize MQTT 1357 1357 1358 --- Initialize MQTT 1359 - 1360 1360 function mymqtt_init() 1361 1361 1362 - 1215 + sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID)) 1363 1363 1364 - , 1) -- Create the object and declare it as a global variable, 1 means using the domain to connect1217 + g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable 1365 1365 1366 - 1219 + if g_mq then 1367 1367 1368 - 1221 + g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks 1369 1369 1370 - 1223 + sprint("mqtt init success") 1371 1371 1372 - 1225 + else 1373 1373 1374 - 1227 + sprint("mqtt init failed:", err) 1375 1375 1376 - 1229 + end 1377 1377 1378 1378 end 1379 1379 1380 --- Connect to MQTT server 1233 +~-~- Connect to MQTT server 1381 1381 1382 1382 function mymqtt_connect() 1383 1383 1384 - 1237 + sprint("mqtt connecting...") 1385 1385 1386 - 1239 + local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART) 1387 1387 1388 - 1241 + if stat == nil then 1389 1389 1390 - 1243 + sprint("mqtt connect failed:", err) 1391 1391 1392 - 1245 + return 1393 1393 1394 - 1247 + else 1395 1395 1396 - 1249 + sprint("mqtt connected") 1397 1397 1398 - 1251 + end 1399 1399 1400 - Subscribe_RE_TOPIC1, 0)1253 + g_mq:subscribe(TEST, 0) 1401 1401 1402 1402 end 1403 1403 1404 --- Receive MQTT message callback function 1257 +~-~- Receive MQTT message callback function 1405 1405 1406 1406 function mymqtt_msg_callback(topic, msg) 1407 1407 1408 - 1261 + print("topic:",topic) 1409 1409 1410 - 1263 + print("revdata:",msg) 1411 1411 1412 - 1265 + local revData = json.decode(msg) 1413 1413 1414 - 1267 + print (revData) 1415 1415 1416 - 1269 + if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud 1417 1417 1418 - 1271 +if string.match(topic,Subscribe_RE_TOPIC1) then 1419 1419 1420 - 1273 + ~-~-if revData ~~= nil then 1421 1421 1422 - 1275 + for k,v in pairs (revData) do 1423 1423 1424 - 1277 + print("printing revdata after kv here") 1425 1425 1426 - 1279 + print (k,v) 1427 1427 1428 - 1281 + end 1429 1429 1430 - 1283 + print ("current state is",fanstate) 1431 1431 1432 - 1285 + ~-~-end 1433 1433 1434 - 1287 +end 1435 1435 1436 - 1289 +end 1437 1437 1438 1438 end 1439 1439 1440 1440 1294 +~-~-Get real-time data 1441 1441 1442 ---Get real-time data 1443 - 1444 1444 function getData() 1445 1445 1446 - 1298 + local jdata = {} 1447 1447 1448 - 1300 + local addr = bns_get_alldata() 1449 1449 1450 - 1302 + print(json.encode(addr)) 1451 1451 1452 - 1304 + for i,v in pairs(addr) do 1453 1453 1454 - 1306 + if v[2] == 1 then 1455 1455 1456 - 1308 + jdata[v[3]] = v[4] 1457 1457 1458 - 1310 + end 1459 1459 1460 - 1312 + end 1461 1461 1462 - 1314 + return jdata 1463 1463 1464 1464 end 1465 1465 1466 ---send data 1318 +~-~-send data 1467 1467 1468 1468 function send_Data() 1469 1469 1470 - local pub_data = 1471 - { 1472 - 123 1473 - } 1322 + local pub_data = 1474 1474 1324 + { 1325 + 1326 +123 1327 + 1328 +} 1329 + 1475 1475 sprint(json.encode(pub_data)) 1476 1476 1477 1477 print("..........",pub_RE_TOPIC) 1478 1478 1479 - 1334 + return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0) 1480 1480 1481 1481 end 1482 -{{/code}} 1483 1483 1484 1484 Get message in AWS 1485 1485
- InputHTTPparameter.png
-
- Author
-
... ... @@ -1,1 +1,0 @@ 1 -XWiki.Hunter - Size
-
... ... @@ -1,1 +1,0 @@ 1 -17.9 KB - Content