Skip to Content

Changes for page 2 Script

Last modified by Devin Chen on 2025/06/06 14:03
From version 38.1
edited by Hunter
on 2023/03/17 14:43
Change comment: There is no comment for this version
To version 27.1
edited by Hunter
on 2022/10/25 09:39
Change comment: There is no comment for this version

Summary

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]]**
... ... @@ -600,134 +600,142 @@
600 600  -- Meta class
601 601  --main
602 602  function mq.main()
603 - if not mq.m then
604 - local err = ""
504 + if not mq.m then
505 +  local err = ""
605 605  
606 - mq.m, err = mqtt.create("tcp://grouprobotinfo.com:1883", "ClienID") -- create connection
607 - if mq.m then
608 - mq.config = {
609 - username = "",-- ID
610 - password = "",-- password
611 - netway = 1, -- Ethernet connection, WIFI=1
612 - -- keepalive = 100, -- Optional, set the connection heartbeat interval for 100 seconds.
613 - -- cleansession = 0, -- Optional, keep session
614 - }
615 - mq.m:on("message", function(topic, msg) -- Register for receiving message callbacks
616 - local str = string.format("%s:%s", topic, msg)
617 - -- print("mqtt msg:", str) -- Print out the received topics and content
618 - end)
619 - mq.m:on("offline", function (cause) -- Register for lost connection callbacks
620 - -- addr_setstring("@xxx", "cause"..(cause or " got nil"))
621 - end)
622 - mq.m:on("arrived", function() -- Registration for sending messages to callbacks
623 - print("msg arrived")
624 - end)
625 - else
626 - print("mqtt create failed:", err) -- Create object failed
627 - end
628 - else
629 - if mq.m:isconnected() then -- If online, post a message
630 - local phaseStatus ="unknow"
631 - if addr_getbit("@Standby")== 1 then
632 - phaseStatus = "Standby"
633 - elseif addr_getbit("@Pre-Freeze")==1 then
634 - phaseStatus= "Pre-Freeze"
635 - elseif addr_getbit("@Prepare")==1 then
636 - phaseStatus ="Prepare"
637 - elseif addr_getbit("@Primary Dry")==1 then
638 - phaseStatus = "Primary dry"
639 - elseif addr_getbit("@Secondary Dry")==1 then
640 - phaseStatus = "Secondary Dry"
641 - end
642 - --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"))
643 643  -------------------------------------------------------------------------------------------------------------------------
644 - local activating ="unknow"
645 - if addr_getbit("@Compressor")==1 then
646 - activating = ",".."Compressor"
647 - end
648 - if addr_getbit("@Silicone Pump")==1 then
649 - activating = activating..",".."Silicone Pump"
650 - end
651 - if addr_getbit("@Vacuum Pump")==1 then
652 - activating = activating..",".."Vacuum Pump"
653 - end
654 - if addr_getbit("@Root Pump")==1 then
655 - activating = activating..",".."Root Pump"
656 - end
657 - if addr_getbit("@Heater")==1 then
658 - activating = activating..",".."Heater"
659 - end
660 - if addr_getbit("@Valve Silicone")==1 then
661 - activating = activating..",".."Valve Silicone"
662 - end
663 - if addr_getbit("@Valve Ice Condenser")==1 then
664 - activating = activating..",".."Valve Ice Condenser"
665 - end
666 - if addr_getbit("@Valve Vacuum Pump")==1 then
667 - activating = activating..",".."Valve Vacuum Pump"
668 - end
669 - local pr_activating =string.sub(activating,2)
670 - -- print(pr_activating)
671 - local status_text ="unknow"
672 - if addr_getbit("@Status Run")==1 then
673 - status_text = "RUNNING"
674 - else
675 - status_text = "STOP"
676 - end
677 --------------------------------------------------------------------------------------------------------------------------
678 - local js = {type="status",
679 - mc_name ="FD300",
680 - status=status_text,
681 - elapsed_time={
682 - hour=addr_getword("@Elapsed Time (Hour)"),
683 - min=addr_getword("@Elapsed Time (Minute)"),
684 - sec=addr_getword("@Elapsed Time (Second)")
685 - },
686 - phase = phaseStatus,
687 - step = addr_getword("@Step"),
688 - activating_output = pr_activating,
689 - sv=addr_getshort("@SV Silicone")/10,
690 - pv=addr_getshort("@PV Silicone")/10,
691 - 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)  
692 692  
693 - product2=addr_getshort("@Product 2")/10,
694 - product3=addr_getshort("@Product 3")/10,
695 - product4=addr_getshort("@Product 4")/10,
696 - ice1=addr_getshort("@Ice condenser 1")/10,
697 - ice2=addr_getshort("@Ice condenser 2")/10,
698 - vacuum=addr_getfloat("@Vacuum")
699 - }
700 - local jsAlarm = { HPC = addr_getbit("@B_25395#W0.00"),
701 - ODPC = addr_getbit("@B_25395#W0.01"),
702 - MTPC=addr_getbit("@B_25395#W0.02"),
703 - HTT = addr_getbit("@B_25395#W1.03"),
704 - CPC = addr_getbit("@B_25395#W0.08"),
705 - CPSP =addr_getbit("@B_25395#W1.00"),
706 - CPVP =addr_getbit("@B_25395#W0.10"),
707 - CPRP =addr_getbit("@B_25395#W0.11"),
708 - HP =addr_getbit("@B_25395#W1.01"),
709 - PP= addr_getbit("@B_25395#W1.02"),
710 - PO=addr_getbit("@B_25395#W0.07"),
711 - FSE=addr_getbit("@B_25395#W2.04"),
712 - AVVSVV=addr_getbit("@B_25395#W1.12"),
713 - ICHT=addr_getbit("@B_25395#W3.06")
714 - }
715 - -- ("@B_25395#CIO1.02")
716 - mq.m:publish("mqtt-v-box-epsilon-fd300", json.encode(js) , 0, 0)
717 - mq.m:publish("mqtt-v-box-epsilon-alarm-fd300", json.encode(jsAlarm) , 0, 0)
718 - else
719 - local stat, err = mq.m:connect(mq.config) -- connection
720 - if stat == nil then --Determine whether to connect
721 - print("mqtt connect failed:", err)
722 - return -- Connection failed, return directly
723 - end
724 - mq.m:subscribe("mqtt-v-box-epsilon", 0)-- Subscribe to topics
725 725  
726 - end
727 - -- mq.m:unsubscribe("stc/test")
728 - -- mq.m:disconnect() -- close matt
729 - -- mq.m:close() -- close clase
730 - 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
731 731  end
732 732  {{/code}}
733 733  
... ... @@ -1157,20 +1157,35 @@
1157 1157  
1158 1158  {{code language="java"}}
1159 1159  {
1069 +
1160 1160    "Version": "2012-10-17",
1071 +
1161 1161    "Statement": [
1073 +
1162 1162      {
1075 +
1163 1163        "Effect": "Allow",
1077 +
1164 1164        "Action": [
1079 +
1165 1165          "iot:Connect",
1081 +
1166 1166          "iot:Publish",
1083 +
1167 1167          "iot:Subscribe",
1085 +
1168 1168          "iot:Receive",
1087 +
1169 1169          "greengrass:Discover"
1089 +
1170 1170        ],
1091 +
1171 1171        "Resource": "*"
1093 +
1172 1172      }
1095 +
1173 1173    ]
1097 +
1174 1174  }
1175 1175  {{/code}}
1176 1176  
... ... @@ -1235,190 +1235,185 @@
1235 1235  
1236 1236  [[image:image-20220709165402-20.png]]
1237 1237  
1238 -{{info}}
1239 -**✎Note:** Before using the following demo script, please make sure the V-Box firmware is newer than 22110701
1240 -{{/info}}
1241 -
1242 -{{code language="lua"}}
1243 1243  sprint = print
1244 1244  
1245 ---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)
1246 1246  
1247 1247  local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg()
1248 1248  
1249 ---publish to topics
1168 +~-~-publish to topics
1250 1250  
1251 1251  local pub_RE_TOPIC = string.format('TEST')
1252 1252  
1253 ---Subscribe topics
1172 +~-~-Subscribe topics
1254 1254  
1255 1255  local Subscribe_RE_TOPIC1 = string.format('TEST')
1256 1256  
1257 ---variable
1176 +~-~-variable
1258 1258  
1259 1259  local last_time = 0
1260 1260  
1261 ---Timing main function
1180 +~-~-Timing main function
1262 1262  
1263 1263  function aws.main()
1264 1264  
1265 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
1184 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
1266 1266  
1267 - if g_mq then
1186 + if g_mq then
1268 1268  
1269 - if g_mq:isconnected() then
1188 + if g_mq:isconnected() then
1270 1270  
1271 - send_Data()
1190 + send_Data()
1272 1272  
1273 - else
1192 + else
1274 1274  
1275 - if os.time() - last_time > 5 then
1194 + if os.time() - last_time > 5 then
1276 1276  
1277 - last_time = os.time()
1196 + last_time = os.time()
1278 1278  
1279 - mymqtt_connect()
1198 + mymqtt_connect()
1280 1280  
1281 - end
1282 -
1283 1283   end
1284 1284  
1285 - else
1202 + end
1286 1286  
1287 - mymqtt_init()
1204 + else
1288 1288  
1289 - end
1206 + mymqtt_init()
1290 1290  
1291 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1208 + end
1292 1292  
1210 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1211 +
1293 1293  end
1294 1294  
1295 1295  
1215 +~-~- Initialize MQTT
1296 1296  
1297 --- Initialize MQTT
1298 -
1299 1299  function mymqtt_init()
1300 1300  
1301 - sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
1219 + sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
1302 1302  
1303 - g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID, 1) -- Create the object and declare it as a global variable, 1 means using the domain to connect
1221 + g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable
1304 1304  
1305 - if g_mq then
1223 + if g_mq then
1306 1306  
1307 - g_mq:on("message", mymqtt_msg_callback) -- Register to receive message callbacks
1225 + g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks
1308 1308  
1309 - sprint("mqtt init success")
1227 + sprint("mqtt init success")
1310 1310  
1311 - else
1229 + else
1312 1312  
1313 - sprint("mqtt init failed:", err)
1231 + sprint("mqtt init failed:", err)
1314 1314  
1315 - end
1233 + end
1316 1316  
1317 1317  end
1318 1318  
1319 --- Connect to MQTT server
1237 +~-~- Connect to MQTT server
1320 1320  
1321 1321  function mymqtt_connect()
1322 1322  
1323 - sprint("mqtt connecting...")
1241 + sprint("mqtt connecting...")
1324 1324  
1325 - local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1243 + local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1326 1326  
1327 - if stat == nil then
1245 + if stat == nil then
1328 1328  
1329 - sprint("mqtt connect failed:", err)
1247 + sprint("mqtt connect failed:", err)
1330 1330  
1331 - return
1249 + return
1332 1332  
1333 - else
1251 + else
1334 1334  
1335 - sprint("mqtt connected")
1253 + sprint("mqtt connected")
1336 1336  
1337 - end
1255 + end
1338 1338  
1339 - g_mq:subscribe(Subscribe_RE_TOPIC1, 0)
1257 + g_mq:subscribe(TEST, 0)
1340 1340  
1341 1341  end
1342 1342  
1343 --- Receive MQTT message callback function
1261 +~-~- Receive MQTT message callback function
1344 1344  
1345 1345  function mymqtt_msg_callback(topic, msg)
1346 1346  
1347 - print("topic:",topic)
1265 + print("topic:",topic)
1348 1348  
1349 - print("revdata:",msg)
1267 + print("revdata:",msg)
1350 1350  
1351 - local revData = json.decode(msg)
1269 + local revData = json.decode(msg)
1352 1352  
1353 - print (revData)
1271 + print (revData)
1354 1354  
1355 - if topic == Subscribe_RE_TOPIC1 then --Process topic information subscribed from the cloud
1273 + if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud
1356 1356  
1357 - if string.match(topic,Subscribe_RE_TOPIC1) then
1275 +if string.match(topic,Subscribe_RE_TOPIC1) then
1358 1358  
1359 - --if revData ~= nil then
1277 + ~-~-if revData ~~= nil then
1360 1360  
1361 - for k,v in pairs (revData) do
1279 + for k,v in pairs (revData) do
1362 1362  
1363 - print("printing revdata after kv here")
1281 + print("printing revdata after kv here")
1364 1364  
1365 - print (k,v)
1283 + print (k,v)
1366 1366  
1367 - end
1285 + end
1368 1368  
1369 - print ("current state is",fanstate)
1287 + print ("current state is",fanstate)
1370 1370  
1371 - --end
1289 + ~-~-end
1372 1372  
1373 - end
1291 +end
1374 1374  
1375 - end
1293 +end
1376 1376  
1377 1377  end
1378 1378  
1379 1379  
1298 +~-~-Get real-time data
1380 1380  
1381 ---Get real-time data
1382 -
1383 1383  function getData()
1384 1384  
1385 - local jdata = {}
1302 + local jdata = {}
1386 1386  
1387 - local addr = bns_get_alldata()
1304 + local addr = bns_get_alldata()
1388 1388  
1389 - print(json.encode(addr))
1306 + print(json.encode(addr))
1390 1390  
1391 - for i,v in pairs(addr) do
1308 + for i,v in pairs(addr) do
1392 1392  
1393 - if v[2] == 1 then
1310 + if v[2] == 1 then
1394 1394  
1395 - jdata[v[3]] = v[4]
1312 + jdata[v[3]] = v[4]
1396 1396  
1397 - end
1314 + end
1398 1398  
1399 - end
1316 + end
1400 1400  
1401 - return jdata
1318 + return jdata
1402 1402  
1403 1403  end
1404 1404  
1405 ---send data
1322 +~-~-send data
1406 1406  
1407 1407  function send_Data()
1408 1408  
1409 - local pub_data =
1410 - {
1411 - 123
1412 - }
1326 + local pub_data =
1413 1413  
1328 + {
1329 +
1330 +123
1331 +
1332 +}
1333 +
1414 1414  sprint(json.encode(pub_data))
1415 1415  
1416 1416  print("..........",pub_RE_TOPIC)
1417 1417  
1418 - return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
1338 + return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
1419 1419  
1420 1420  end
1421 -{{/code}}
1422 1422  
1423 1423  Get message in AWS
1424 1424  
InputHTTPparameter.png
Author
... ... @@ -1,1 +1,0 @@
1 -XWiki.Hunter
Size
... ... @@ -1,1 +1,0 @@
1 -17.9 KB
Content