Skip to Content

Changes for page 2 Script

Last modified by Devin Chen on 2025/06/06 14:03
From version 49.1
edited by Hunter
on 2023/05/06 10:09
Change comment: There is no comment for this version
To version 28.1
edited by Hunter
on 2022/11/21 17:01
Change comment: There is no comment for this version

Summary

Details

Page properties
Content
... ... @@ -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}}
370 +(% 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 5 sec not connect, reconnect once
638 - if os.time() - LAST_TIME > 5 then
479 + --if exceed 20 sec not connect, reconnect once
480 + 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
... ... @@ -1218,20 +1218,35 @@
1218 1218  
1219 1219  {{code language="java"}}
1220 1220  {
1061 +
1221 1221    "Version": "2012-10-17",
1063 +
1222 1222    "Statement": [
1065 +
1223 1223      {
1067 +
1224 1224        "Effect": "Allow",
1069 +
1225 1225        "Action": [
1071 +
1226 1226          "iot:Connect",
1073 +
1227 1227          "iot:Publish",
1075 +
1228 1228          "iot:Subscribe",
1077 +
1229 1229          "iot:Receive",
1079 +
1230 1230          "greengrass:Discover"
1081 +
1231 1231        ],
1083 +
1232 1232        "Resource": "*"
1085 +
1233 1233      }
1087 +
1234 1234    ]
1089 +
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)
1156 +~-~-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
1160 +~-~-publish to topics
1311 1311  
1312 1312  local pub_RE_TOPIC = string.format('TEST')
1313 1313  
1314 ---Subscribe topics
1164 +~-~-Subscribe topics
1315 1315  
1316 1316  local Subscribe_RE_TOPIC1 = string.format('TEST')
1317 1317  
1318 ---variable
1168 +~-~-variable
1319 1319  
1320 1320  local last_time = 0
1321 1321  
1322 ---Timing main function
1172 +~-~-Timing main function
1323 1323  
1324 1324  function aws.main()
1325 1325  
1326 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
1176 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
1327 1327  
1328 - if g_mq then
1178 + if g_mq then
1329 1329  
1330 - if g_mq:isconnected() then
1180 + if g_mq:isconnected() then
1331 1331  
1332 - send_Data()
1182 + send_Data()
1333 1333  
1334 - else
1184 + else
1335 1335  
1336 - if os.time() - last_time > 5 then
1186 + if os.time() - last_time > 5 then
1337 1337  
1338 - last_time = os.time()
1188 + last_time = os.time()
1339 1339  
1340 - mymqtt_connect()
1190 + mymqtt_connect()
1341 1341  
1342 - end
1343 -
1344 1344   end
1345 1345  
1346 - else
1194 + end
1347 1347  
1348 - mymqtt_init()
1196 + else
1349 1349  
1350 - end
1198 + mymqtt_init()
1351 1351  
1352 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1200 + end
1353 1353  
1202 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1203 +
1354 1354  end
1355 1355  
1356 1356  
1207 +~-~- Initialize MQTT
1357 1357  
1358 --- Initialize MQTT
1359 -
1360 1360  function mymqtt_init()
1361 1361  
1362 - sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
1211 + sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
1363 1363  
1364 - 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
1213 + g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable
1365 1365  
1366 - if g_mq then
1215 + if g_mq then
1367 1367  
1368 - g_mq:on("message", mymqtt_msg_callback) -- Register to receive message callbacks
1217 + g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks
1369 1369  
1370 - sprint("mqtt init success")
1219 + sprint("mqtt init success")
1371 1371  
1372 - else
1221 + else
1373 1373  
1374 - sprint("mqtt init failed:", err)
1223 + sprint("mqtt init failed:", err)
1375 1375  
1376 - end
1225 + end
1377 1377  
1378 1378  end
1379 1379  
1380 --- Connect to MQTT server
1229 +~-~- Connect to MQTT server
1381 1381  
1382 1382  function mymqtt_connect()
1383 1383  
1384 - sprint("mqtt connecting...")
1233 + sprint("mqtt connecting...")
1385 1385  
1386 - local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1235 + local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1387 1387  
1388 - if stat == nil then
1237 + if stat == nil then
1389 1389  
1390 - sprint("mqtt connect failed:", err)
1239 + sprint("mqtt connect failed:", err)
1391 1391  
1392 - return
1241 + return
1393 1393  
1394 - else
1243 + else
1395 1395  
1396 - sprint("mqtt connected")
1245 + sprint("mqtt connected")
1397 1397  
1398 - end
1247 + end
1399 1399  
1400 - g_mq:subscribe(Subscribe_RE_TOPIC1, 0)
1249 + g_mq:subscribe(TEST, 0)
1401 1401  
1402 1402  end
1403 1403  
1404 --- Receive MQTT message callback function
1253 +~-~- Receive MQTT message callback function
1405 1405  
1406 1406  function mymqtt_msg_callback(topic, msg)
1407 1407  
1408 - print("topic:",topic)
1257 + print("topic:",topic)
1409 1409  
1410 - print("revdata:",msg)
1259 + print("revdata:",msg)
1411 1411  
1412 - local revData = json.decode(msg)
1261 + local revData = json.decode(msg)
1413 1413  
1414 - print (revData)
1263 + print (revData)
1415 1415  
1416 - if topic == Subscribe_RE_TOPIC1 then --Process topic information subscribed from the cloud
1265 + if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud
1417 1417  
1418 - if string.match(topic,Subscribe_RE_TOPIC1) then
1267 +if string.match(topic,Subscribe_RE_TOPIC1) then
1419 1419  
1420 - --if revData ~= nil then
1269 + ~-~-if revData ~~= nil then
1421 1421  
1422 - for k,v in pairs (revData) do
1271 + for k,v in pairs (revData) do
1423 1423  
1424 - print("printing revdata after kv here")
1273 + print("printing revdata after kv here")
1425 1425  
1426 - print (k,v)
1275 + print (k,v)
1427 1427  
1428 - end
1277 + end
1429 1429  
1430 - print ("current state is",fanstate)
1279 + print ("current state is",fanstate)
1431 1431  
1432 - --end
1281 + ~-~-end
1433 1433  
1434 - end
1283 +end
1435 1435  
1436 - end
1285 +end
1437 1437  
1438 1438  end
1439 1439  
1440 1440  
1290 +~-~-Get real-time data
1441 1441  
1442 ---Get real-time data
1443 -
1444 1444  function getData()
1445 1445  
1446 - local jdata = {}
1294 + local jdata = {}
1447 1447  
1448 - local addr = bns_get_alldata()
1296 + local addr = bns_get_alldata()
1449 1449  
1450 - print(json.encode(addr))
1298 + print(json.encode(addr))
1451 1451  
1452 - for i,v in pairs(addr) do
1300 + for i,v in pairs(addr) do
1453 1453  
1454 - if v[2] == 1 then
1302 + if v[2] == 1 then
1455 1455  
1456 - jdata[v[3]] = v[4]
1304 + jdata[v[3]] = v[4]
1457 1457  
1458 - end
1306 + end
1459 1459  
1460 - end
1308 + end
1461 1461  
1462 - return jdata
1310 + return jdata
1463 1463  
1464 1464  end
1465 1465  
1466 ---send data
1314 +~-~-send data
1467 1467  
1468 1468  function send_Data()
1469 1469  
1470 - local pub_data =
1471 - {
1472 - 123
1473 - }
1318 + local pub_data =
1474 1474  
1320 + {
1321 +
1322 +123
1323 +
1324 +}
1325 +
1475 1475  sprint(json.encode(pub_data))
1476 1476  
1477 1477  print("..........",pub_RE_TOPIC)
1478 1478  
1479 - return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
1330 + 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