Skip to Content

Changes for page 2 Script

Last modified by Devin Chen on 2025/06/06 14:03
From version 24.1
edited by Hunter
on 2022/10/09 15:02
Change comment: There is no comment for this version
To version 34.1
edited by Hunter
on 2022/11/22 15:39
Change comment: There is no comment for this version

Summary

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
... ... @@ -218,6 +218,10 @@
218 218  
219 219  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.
220 220  
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 +
221 221  {{code language="Lua"}}
222 222  local tempBit = 0
223 223  local tempWord = 0
... ... @@ -226,8 +226,8 @@
226 226  local json = require("json")
227 227  local ltn12 = require("ltn12")
228 228  
229 -local SID = 'AC1703bd710ffa98006d2bcc0b8d6ca63a'
230 -local Token = 'd3c11897623c39e538b20263ec190ae0'
239 +local SID = 'AC1703bd710ffa98006d2bcc0b********'
240 +local Token = 'd3c11897623c39e538b20263ec19****'
231 231  
232 232  local twilioPhoneNumber = '+14155238886'
233 233  local receiverPhoneNumber = '+8615880018277'
... ... @@ -339,6 +339,104 @@
339 339  end
340 340  {{/code}}
341 341  
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 +
342 342  = **2 V-Box connect with third part server** =
343 343  
344 344  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.
... ... @@ -491,142 +491,134 @@
491 491  -- Meta class
492 492  --main
493 493  function mq.main()
494 - if not mq.m then
495 -  local err = ""
602 + if not mq.m then
603 + local err = ""
496 496  
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"))
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"))
535 535  -------------------------------------------------------------------------------------------------------------------------
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)  
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,
563 563  
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
564 564  
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
725 + end
726 + -- mq.m:unsubscribe("stc/test")
727 + -- mq.m:disconnect() -- close matt
728 + -- mq.m:close() -- close clase
729 + end
630 630  end
631 631  {{/code}}
632 632  
... ... @@ -1056,35 +1056,20 @@
1056 1056  
1057 1057  {{code language="java"}}
1058 1058  {
1059 -
1060 1060    "Version": "2012-10-17",
1061 -
1062 1062    "Statement": [
1063 -
1064 1064      {
1065 -
1066 1066        "Effect": "Allow",
1067 -
1068 1068        "Action": [
1069 -
1070 1070          "iot:Connect",
1071 -
1072 1072          "iot:Publish",
1073 -
1074 1074          "iot:Subscribe",
1075 -
1076 1076          "iot:Receive",
1077 -
1078 1078          "greengrass:Discover"
1079 -
1080 1080        ],
1081 -
1082 1082        "Resource": "*"
1083 -
1084 1084      }
1085 -
1086 1086    ]
1087 -
1088 1088  }
1089 1089  {{/code}}
1090 1090  
... ... @@ -1149,185 +1149,186 @@
1149 1149  
1150 1150  [[image:image-20220709165402-20.png]]
1151 1151  
1237 +{{code language="lua"}}
1152 1152  sprint = print
1153 1153  
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)
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)
1155 1155  
1156 1156  local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg()
1157 1157  
1158 -~-~-publish to topics
1244 +--publish to topics
1159 1159  
1160 1160  local pub_RE_TOPIC = string.format('TEST')
1161 1161  
1162 -~-~-Subscribe topics
1248 +--Subscribe topics
1163 1163  
1164 1164  local Subscribe_RE_TOPIC1 = string.format('TEST')
1165 1165  
1166 -~-~-variable
1252 +--variable
1167 1167  
1168 1168  local last_time = 0
1169 1169  
1170 -~-~-Timing main function
1256 +--Timing main function
1171 1171  
1172 1172  function aws.main()
1173 1173  
1174 - 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")
1175 1175  
1176 - if g_mq then
1262 + if g_mq then
1177 1177  
1178 - if g_mq:isconnected() then
1264 + if g_mq:isconnected() then
1179 1179  
1180 - send_Data()
1266 + send_Data()
1181 1181  
1182 - else
1268 + else
1183 1183  
1184 - if os.time() - last_time > 5 then
1270 + if os.time() - last_time > 5 then
1185 1185  
1186 - last_time = os.time()
1272 + last_time = os.time()
1187 1187  
1188 - mymqtt_connect()
1274 + mymqtt_connect()
1189 1189  
1276 + end
1277 +
1190 1190   end
1191 1191  
1192 - end
1280 + else
1193 1193  
1194 - else
1282 + mymqtt_init()
1195 1195  
1196 - mymqtt_init()
1284 + end
1197 1197  
1198 - end
1286 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1199 1199  
1200 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1201 -
1202 1202  end
1203 1203  
1204 1204  
1205 -~-~- Initialize MQTT
1206 1206  
1292 +-- Initialize MQTT
1293 +
1207 1207  function mymqtt_init()
1208 1208  
1209 - 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))
1210 1210  
1211 - g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable
1298 + g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) -- Create the object and declare it as a global variable
1212 1212  
1213 - if g_mq then
1300 + if g_mq then
1214 1214  
1215 - g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks
1302 + g_mq:on("message", mymqtt_msg_callback) -- Register to receive message callbacks
1216 1216  
1217 - sprint("mqtt init success")
1304 + sprint("mqtt init success")
1218 1218  
1219 - else
1306 + else
1220 1220  
1221 - sprint("mqtt init failed:", err)
1308 + sprint("mqtt init failed:", err)
1222 1222  
1223 - end
1310 + end
1224 1224  
1225 1225  end
1226 1226  
1227 -~-~- Connect to MQTT server
1314 +-- Connect to MQTT server
1228 1228  
1229 1229  function mymqtt_connect()
1230 1230  
1231 - sprint("mqtt connecting...")
1318 + sprint("mqtt connecting...")
1232 1232  
1233 - 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)
1234 1234  
1235 - if stat == nil then
1322 + if stat == nil then
1236 1236  
1237 - sprint("mqtt connect failed:", err)
1324 + sprint("mqtt connect failed:", err)
1238 1238  
1239 - return
1326 + return
1240 1240  
1241 - else
1328 + else
1242 1242  
1243 - sprint("mqtt connected")
1330 + sprint("mqtt connected")
1244 1244  
1245 - end
1332 + end
1246 1246  
1247 - g_mq:subscribe(TEST, 0)
1334 + g_mq:subscribe(Subscribe_RE_TOPIC1, 0)
1248 1248  
1249 1249  end
1250 1250  
1251 -~-~- Receive MQTT message callback function
1338 +-- Receive MQTT message callback function
1252 1252  
1253 1253  function mymqtt_msg_callback(topic, msg)
1254 1254  
1255 - print("topic:",topic)
1342 + print("topic:",topic)
1256 1256  
1257 - print("revdata:",msg)
1344 + print("revdata:",msg)
1258 1258  
1259 - local revData = json.decode(msg)
1346 + local revData = json.decode(msg)
1260 1260  
1261 - print (revData)
1348 + print (revData)
1262 1262  
1263 - if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud
1350 + if topic == Subscribe_RE_TOPIC1 then --Process topic information subscribed from the cloud
1264 1264  
1265 -if string.match(topic,Subscribe_RE_TOPIC1) then
1352 + if string.match(topic,Subscribe_RE_TOPIC1) then
1266 1266  
1267 - ~-~-if revData ~~= nil then
1354 + --if revData ~= nil then
1268 1268  
1269 - for k,v in pairs (revData) do
1356 + for k,v in pairs (revData) do
1270 1270  
1271 - print("printing revdata after kv here")
1358 + print("printing revdata after kv here")
1272 1272  
1273 - print (k,v)
1360 + print (k,v)
1274 1274  
1275 - end
1362 + end
1276 1276  
1277 - print ("current state is",fanstate)
1364 + print ("current state is",fanstate)
1278 1278  
1279 - ~-~-end
1366 + --end
1280 1280  
1281 -end
1368 + end
1282 1282  
1283 -end
1370 + end
1284 1284  
1285 1285  end
1286 1286  
1287 1287  
1288 -~-~-Get real-time data
1289 1289  
1376 +--Get real-time data
1377 +
1290 1290  function getData()
1291 1291  
1292 - local jdata = {}
1380 + local jdata = {}
1293 1293  
1294 - local addr = bns_get_alldata()
1382 + local addr = bns_get_alldata()
1295 1295  
1296 - print(json.encode(addr))
1384 + print(json.encode(addr))
1297 1297  
1298 - for i,v in pairs(addr) do
1386 + for i,v in pairs(addr) do
1299 1299  
1300 - if v[2] == 1 then
1388 + if v[2] == 1 then
1301 1301  
1302 - jdata[v[3]] = v[4]
1390 + jdata[v[3]] = v[4]
1303 1303  
1304 - end
1392 + end
1305 1305  
1306 - end
1394 + end
1307 1307  
1308 - return jdata
1396 + return jdata
1309 1309  
1310 1310  end
1311 1311  
1312 -~-~-send data
1400 +--send data
1313 1313  
1314 1314  function send_Data()
1315 1315  
1316 - local pub_data =
1404 + local pub_data =
1405 + {
1406 + 123
1407 + }
1317 1317  
1318 - {
1319 -
1320 -123
1321 -
1322 -}
1323 -
1324 1324  sprint(json.encode(pub_data))
1325 1325  
1326 1326  print("..........",pub_RE_TOPIC)
1327 1327  
1328 - 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)
1329 1329  
1330 1330  end
1416 +{{/code}}
1331 1331  
1332 1332  Get message in AWS
1333 1333  
InputHTTPparameter.png
Author
... ... @@ -1,0 +1,1 @@
1 +XWiki.Hunter
Size
... ... @@ -1,0 +1,1 @@
1 +17.9 KB
Content