Changes for page 2 Script

Last modified by Devin Chen on 2025/06/06 14:03

From version 33.1
edited by Hunter
on 2022/11/22 15:38
Change comment: There is no comment for this version
To version 26.1
edited by Hunter
on 2022/10/25 09:36
Change comment: There is no comment for this version

Summary

Details

Page properties
Content
... ... @@ -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,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.
... ... @@ -599,134 +599,142 @@
599 599  -- Meta class
600 600  --main
601 601  function mq.main()
602 - if not mq.m then
603 - local err = ""
500 + if not mq.m then
501 +  local err = ""
604 604  
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"))
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"))
642 642  -------------------------------------------------------------------------------------------------------------------------
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,
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)  
691 691  
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
724 724  
725 - end
726 - -- mq.m:unsubscribe("stc/test")
727 - -- mq.m:disconnect() -- close matt
728 - -- mq.m:close() -- close clase
729 - 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
730 730  end
731 731  {{/code}}
732 732  
... ... @@ -1156,20 +1156,35 @@
1156 1156  
1157 1157  {{code language="java"}}
1158 1158  {
1065 +
1159 1159    "Version": "2012-10-17",
1067 +
1160 1160    "Statement": [
1069 +
1161 1161      {
1071 +
1162 1162        "Effect": "Allow",
1073 +
1163 1163        "Action": [
1075 +
1164 1164          "iot:Connect",
1077 +
1165 1165          "iot:Publish",
1079 +
1166 1166          "iot:Subscribe",
1081 +
1167 1167          "iot:Receive",
1083 +
1168 1168          "greengrass:Discover"
1085 +
1169 1169        ],
1087 +
1170 1170        "Resource": "*"
1089 +
1171 1171      }
1091 +
1172 1172    ]
1093 +
1173 1173  }
1174 1174  {{/code}}
1175 1175  
... ... @@ -1234,186 +1234,185 @@
1234 1234  
1235 1235  [[image:image-20220709165402-20.png]]
1236 1236  
1237 -{{code language="lua"}}
1238 1238  sprint = print
1239 1239  
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)
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)
1241 1241  
1242 1242  local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg()
1243 1243  
1244 ---publish to topics
1164 +~-~-publish to topics
1245 1245  
1246 1246  local pub_RE_TOPIC = string.format('TEST')
1247 1247  
1248 ---Subscribe topics
1168 +~-~-Subscribe topics
1249 1249  
1250 1250  local Subscribe_RE_TOPIC1 = string.format('TEST')
1251 1251  
1252 ---variable
1172 +~-~-variable
1253 1253  
1254 1254  local last_time = 0
1255 1255  
1256 ---Timing main function
1176 +~-~-Timing main function
1257 1257  
1258 1258  function aws.main()
1259 1259  
1260 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
1180 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
1261 1261  
1262 - if g_mq then
1182 + if g_mq then
1263 1263  
1264 - if g_mq:isconnected() then
1184 + if g_mq:isconnected() then
1265 1265  
1266 - send_Data()
1186 + send_Data()
1267 1267  
1268 - else
1188 + else
1269 1269  
1270 - if os.time() - last_time > 5 then
1190 + if os.time() - last_time > 5 then
1271 1271  
1272 - last_time = os.time()
1192 + last_time = os.time()
1273 1273  
1274 - mymqtt_connect()
1194 + mymqtt_connect()
1275 1275  
1276 - end
1277 -
1278 1278   end
1279 1279  
1280 - else
1198 + end
1281 1281  
1282 - mymqtt_init()
1200 + else
1283 1283  
1284 - end
1202 + mymqtt_init()
1285 1285  
1286 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1204 + end
1287 1287  
1206 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1207 +
1288 1288  end
1289 1289  
1290 1290  
1211 +~-~- Initialize MQTT
1291 1291  
1292 --- Initialize MQTT
1293 -
1294 1294  function mymqtt_init()
1295 1295  
1296 - sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
1215 + sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
1297 1297  
1298 - g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) -- Create the object and declare it as a global variable
1217 + g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable
1299 1299  
1300 - if g_mq then
1219 + if g_mq then
1301 1301  
1302 - g_mq:on("message", mymqtt_msg_callback) -- Register to receive message callbacks
1221 + g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks
1303 1303  
1304 - sprint("mqtt init success")
1223 + sprint("mqtt init success")
1305 1305  
1306 - else
1225 + else
1307 1307  
1308 - sprint("mqtt init failed:", err)
1227 + sprint("mqtt init failed:", err)
1309 1309  
1310 - end
1229 + end
1311 1311  
1312 1312  end
1313 1313  
1314 --- Connect to MQTT server
1233 +~-~- Connect to MQTT server
1315 1315  
1316 1316  function mymqtt_connect()
1317 1317  
1318 - sprint("mqtt connecting...")
1237 + sprint("mqtt connecting...")
1319 1319  
1320 - local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1239 + local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1321 1321  
1322 - if stat == nil then
1241 + if stat == nil then
1323 1323  
1324 - sprint("mqtt connect failed:", err)
1243 + sprint("mqtt connect failed:", err)
1325 1325  
1326 - return
1245 + return
1327 1327  
1328 - else
1247 + else
1329 1329  
1330 - sprint("mqtt connected")
1249 + sprint("mqtt connected")
1331 1331  
1332 - end
1251 + end
1333 1333  
1334 - g_mq:subscribe(TEST, 0)
1253 + g_mq:subscribe(TEST, 0)
1335 1335  
1336 1336  end
1337 1337  
1338 --- Receive MQTT message callback function
1257 +~-~- Receive MQTT message callback function
1339 1339  
1340 1340  function mymqtt_msg_callback(topic, msg)
1341 1341  
1342 - print("topic:",topic)
1261 + print("topic:",topic)
1343 1343  
1344 - print("revdata:",msg)
1263 + print("revdata:",msg)
1345 1345  
1346 - local revData = json.decode(msg)
1265 + local revData = json.decode(msg)
1347 1347  
1348 - print (revData)
1267 + print (revData)
1349 1349  
1350 - if topic == Subscribe_RE_TOPIC1 then --Process topic information subscribed from the cloud
1269 + if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud
1351 1351  
1352 - if string.match(topic,Subscribe_RE_TOPIC1) then
1271 +if string.match(topic,Subscribe_RE_TOPIC1) then
1353 1353  
1354 - --if revData ~= nil then
1273 + ~-~-if revData ~~= nil then
1355 1355  
1356 - for k,v in pairs (revData) do
1275 + for k,v in pairs (revData) do
1357 1357  
1358 - print("printing revdata after kv here")
1277 + print("printing revdata after kv here")
1359 1359  
1360 - print (k,v)
1279 + print (k,v)
1361 1361  
1362 - end
1281 + end
1363 1363  
1364 - print ("current state is",fanstate)
1283 + print ("current state is",fanstate)
1365 1365  
1366 - --end
1285 + ~-~-end
1367 1367  
1368 - end
1287 +end
1369 1369  
1370 - end
1289 +end
1371 1371  
1372 1372  end
1373 1373  
1374 1374  
1294 +~-~-Get real-time data
1375 1375  
1376 ---Get real-time data
1377 -
1378 1378  function getData()
1379 1379  
1380 - local jdata = {}
1298 + local jdata = {}
1381 1381  
1382 - local addr = bns_get_alldata()
1300 + local addr = bns_get_alldata()
1383 1383  
1384 - print(json.encode(addr))
1302 + print(json.encode(addr))
1385 1385  
1386 - for i,v in pairs(addr) do
1304 + for i,v in pairs(addr) do
1387 1387  
1388 - if v[2] == 1 then
1306 + if v[2] == 1 then
1389 1389  
1390 - jdata[v[3]] = v[4]
1308 + jdata[v[3]] = v[4]
1391 1391  
1392 - end
1310 + end
1393 1393  
1394 - end
1312 + end
1395 1395  
1396 - return jdata
1314 + return jdata
1397 1397  
1398 1398  end
1399 1399  
1400 ---send data
1318 +~-~-send data
1401 1401  
1402 1402  function send_Data()
1403 1403  
1404 - local pub_data =
1405 - {
1406 - 123
1407 - }
1322 + local pub_data =
1408 1408  
1324 + {
1325 +
1326 +123
1327 +
1328 +}
1329 +
1409 1409  sprint(json.encode(pub_data))
1410 1410  
1411 1411  print("..........",pub_RE_TOPIC)
1412 1412  
1413 - return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
1334 + return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
1414 1414  
1415 1415  end
1416 -{{/code}}
1417 1417  
1418 1418  Get message in AWS
1419 1419  
InputHTTPparameter.png
Author
... ... @@ -1,1 +1,0 @@
1 -XWiki.Hunter
Size
... ... @@ -1,1 +1,0 @@
1 -17.9 KB
Content