Skip to Content

Changes for page 2 Script

Last modified by Devin Chen on 2025/06/06 14:03
From version 45.1
edited by Hunter
on 2023/03/30 16:34
Change comment: There is no comment for this version
To version 30.1
edited by Hunter
on 2022/11/21 17:31
Change comment: There is no comment for this version

Summary

Details

Page properties
Content
... ... @@ -349,6 +349,7 @@
349 349  end
350 350  {{/code}}
351 351  
352 +
352 352  == **1.8 How to parse value from HTTP response body** ==
353 353  
354 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":
... ... @@ -447,20 +447,6 @@
447 447  end
448 448  {{/code}}
449 449  
450 -== **1.9 High-Low Byte Switch** ==
451 -
452 -The following example is converting the floating number from order 1234 to order 3412. 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 464  = **2 V-Box connect with third part server** =
465 465  
466 466  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.
... ... @@ -479,9 +479,8 @@
479 479  
480 480  (% class="mark" %)2.If your server requires SSL certificate to log in,please use OpenCloud.Because only OpenCloud platform can support to upload certificate
481 481  
482 -{{info}}
469 +(% class="wikigeneratedid" %)
483 483  **✎Note: **Before program the script of MQTT, please make sure the server(MQTT broker) can be connected through MQTT Client tool.
484 -{{/info}}
485 485  
486 486  (% class="wikigeneratedid" %)
487 487  Tool link: **[[MQTT.fx>>http://mqttfx.jensd.de/index.php/download]]**
... ... @@ -488,25 +488,6 @@
488 488  
489 489  == **2.1 V-Box connect with test server(General Example)** ==
490 490  
491 -The following example is trying to publish to the topic "testtopic/test/no1/7890", and subscribe the topic "testtopic/test/no1/123456".
492 -
493 -And the JSON message is like follows:
494 -
495 -{{code language="JSON"}}
496 -{
497 - "timestamp": 1631152760,
498 - "messageId": 1,
499 - "event": "test_data",
500 - "mfrs": "HMI/box",
501 - "data":
502 - {
503 - "id" : 1436217747670454274,
504 - "waterlevel" : 48,
505 - "temperture" : 23
506 - }
507 -}
508 -{{/code}}
509 -
510 510  {{code language="lua"}}
511 511  --MQTT configuration table
512 512  local MQTT_CFG={}
... ... @@ -548,13 +548,9 @@
548 548  --initialize mqtt
549 549  function mqtt_init()
550 550   print(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENT_ID))
551 - if g_mq then
552 - mqtt.close() --Close mqtt object
553 - end
554 554   g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENT_ID) -- create mqtt object,and declare it as a global variable
555 555   if g_mq then
556 556   g_mq:on("message", mqtt_msg_callback) -- Register a callback for receiving messages
557 - g_mq:on("offline", mqtt_msg_offline) -- Register a callback for offline
558 558   print("mqtt init success")
559 559   else
560 560   print("mqtt init failed:", err)
... ... @@ -574,11 +574,6 @@
574 574   g_mq:subscribe(SUBSCRIBE_TOPIC, 0)
575 575  end
576 576  
577 ---Offline callback function
578 -function mqtt_msg_offline(cause)
579 - print("mqtt offline, cause:", cause)
580 -end
581 -
582 582  -- Received message callback function
583 583  function mqtt_msg_callback(topic, msg)
584 584   print("topic:", topic)
... ... @@ -617,11 +617,9 @@
617 617   if g_mq:isconnected() then
618 618   send_data()
619 619   else
620 - --if exceed 5 sec not connect, reconnect once
621 - if os.time() - LAST_TIME > 5 then
578 + --if exceed 20 sec not connect, reconnect once
579 + if os.time() - LAST_TIME > 20 then
622 622   LAST_TIME = os.time()
623 - --reinitial the mqtt object
624 - mqtt_init()
625 625   --connect to mqtt or reconnect
626 626   mqtt_connect()
627 627   end
... ... @@ -1201,20 +1201,35 @@
1201 1201  
1202 1202  {{code language="java"}}
1203 1203  {
1160 +
1204 1204    "Version": "2012-10-17",
1162 +
1205 1205    "Statement": [
1164 +
1206 1206      {
1166 +
1207 1207        "Effect": "Allow",
1168 +
1208 1208        "Action": [
1170 +
1209 1209          "iot:Connect",
1172 +
1210 1210          "iot:Publish",
1174 +
1211 1211          "iot:Subscribe",
1176 +
1212 1212          "iot:Receive",
1178 +
1213 1213          "greengrass:Discover"
1180 +
1214 1214        ],
1182 +
1215 1215        "Resource": "*"
1184 +
1216 1216      }
1186 +
1217 1217    ]
1188 +
1218 1218  }
1219 1219  {{/code}}
1220 1220  
... ... @@ -1279,190 +1279,185 @@
1279 1279  
1280 1280  [[image:image-20220709165402-20.png]]
1281 1281  
1282 -{{info}}
1283 -**✎Note:** Before using the following demo script, please make sure the V-Box firmware is newer than 22110701
1284 -{{/info}}
1285 -
1286 -{{code language="lua"}}
1287 1287  sprint = print
1288 1288  
1289 ---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)
1255 +~-~-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)
1290 1290  
1291 1291  local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg()
1292 1292  
1293 ---publish to topics
1259 +~-~-publish to topics
1294 1294  
1295 1295  local pub_RE_TOPIC = string.format('TEST')
1296 1296  
1297 ---Subscribe topics
1263 +~-~-Subscribe topics
1298 1298  
1299 1299  local Subscribe_RE_TOPIC1 = string.format('TEST')
1300 1300  
1301 ---variable
1267 +~-~-variable
1302 1302  
1303 1303  local last_time = 0
1304 1304  
1305 ---Timing main function
1271 +~-~-Timing main function
1306 1306  
1307 1307  function aws.main()
1308 1308  
1309 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
1275 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
1310 1310  
1311 - if g_mq then
1277 + if g_mq then
1312 1312  
1313 - if g_mq:isconnected() then
1279 + if g_mq:isconnected() then
1314 1314  
1315 - send_Data()
1281 + send_Data()
1316 1316  
1317 - else
1283 + else
1318 1318  
1319 - if os.time() - last_time > 5 then
1285 + if os.time() - last_time > 5 then
1320 1320  
1321 - last_time = os.time()
1287 + last_time = os.time()
1322 1322  
1323 - mymqtt_connect()
1289 + mymqtt_connect()
1324 1324  
1325 - end
1326 -
1327 1327   end
1328 1328  
1329 - else
1293 + end
1330 1330  
1331 - mymqtt_init()
1295 + else
1332 1332  
1333 - end
1297 + mymqtt_init()
1334 1334  
1335 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1299 + end
1336 1336  
1301 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1302 +
1337 1337  end
1338 1338  
1339 1339  
1306 +~-~- Initialize MQTT
1340 1340  
1341 --- Initialize MQTT
1342 -
1343 1343  function mymqtt_init()
1344 1344  
1345 - sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
1310 + sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
1346 1346  
1347 - 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
1312 + g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable
1348 1348  
1349 - if g_mq then
1314 + if g_mq then
1350 1350  
1351 - g_mq:on("message", mymqtt_msg_callback) -- Register to receive message callbacks
1316 + g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks
1352 1352  
1353 - sprint("mqtt init success")
1318 + sprint("mqtt init success")
1354 1354  
1355 - else
1320 + else
1356 1356  
1357 - sprint("mqtt init failed:", err)
1322 + sprint("mqtt init failed:", err)
1358 1358  
1359 - end
1324 + end
1360 1360  
1361 1361  end
1362 1362  
1363 --- Connect to MQTT server
1328 +~-~- Connect to MQTT server
1364 1364  
1365 1365  function mymqtt_connect()
1366 1366  
1367 - sprint("mqtt connecting...")
1332 + sprint("mqtt connecting...")
1368 1368  
1369 - local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1334 + local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1370 1370  
1371 - if stat == nil then
1336 + if stat == nil then
1372 1372  
1373 - sprint("mqtt connect failed:", err)
1338 + sprint("mqtt connect failed:", err)
1374 1374  
1375 - return
1340 + return
1376 1376  
1377 - else
1342 + else
1378 1378  
1379 - sprint("mqtt connected")
1344 + sprint("mqtt connected")
1380 1380  
1381 - end
1346 + end
1382 1382  
1383 - g_mq:subscribe(Subscribe_RE_TOPIC1, 0)
1348 + g_mq:subscribe(TEST, 0)
1384 1384  
1385 1385  end
1386 1386  
1387 --- Receive MQTT message callback function
1352 +~-~- Receive MQTT message callback function
1388 1388  
1389 1389  function mymqtt_msg_callback(topic, msg)
1390 1390  
1391 - print("topic:",topic)
1356 + print("topic:",topic)
1392 1392  
1393 - print("revdata:",msg)
1358 + print("revdata:",msg)
1394 1394  
1395 - local revData = json.decode(msg)
1360 + local revData = json.decode(msg)
1396 1396  
1397 - print (revData)
1362 + print (revData)
1398 1398  
1399 - if topic == Subscribe_RE_TOPIC1 then --Process topic information subscribed from the cloud
1364 + if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud
1400 1400  
1401 - if string.match(topic,Subscribe_RE_TOPIC1) then
1366 +if string.match(topic,Subscribe_RE_TOPIC1) then
1402 1402  
1403 - --if revData ~= nil then
1368 + ~-~-if revData ~~= nil then
1404 1404  
1405 - for k,v in pairs (revData) do
1370 + for k,v in pairs (revData) do
1406 1406  
1407 - print("printing revdata after kv here")
1372 + print("printing revdata after kv here")
1408 1408  
1409 - print (k,v)
1374 + print (k,v)
1410 1410  
1411 - end
1376 + end
1412 1412  
1413 - print ("current state is",fanstate)
1378 + print ("current state is",fanstate)
1414 1414  
1415 - --end
1380 + ~-~-end
1416 1416  
1417 - end
1382 +end
1418 1418  
1419 - end
1384 +end
1420 1420  
1421 1421  end
1422 1422  
1423 1423  
1389 +~-~-Get real-time data
1424 1424  
1425 ---Get real-time data
1426 -
1427 1427  function getData()
1428 1428  
1429 - local jdata = {}
1393 + local jdata = {}
1430 1430  
1431 - local addr = bns_get_alldata()
1395 + local addr = bns_get_alldata()
1432 1432  
1433 - print(json.encode(addr))
1397 + print(json.encode(addr))
1434 1434  
1435 - for i,v in pairs(addr) do
1399 + for i,v in pairs(addr) do
1436 1436  
1437 - if v[2] == 1 then
1401 + if v[2] == 1 then
1438 1438  
1439 - jdata[v[3]] = v[4]
1403 + jdata[v[3]] = v[4]
1440 1440  
1441 - end
1405 + end
1442 1442  
1443 - end
1407 + end
1444 1444  
1445 - return jdata
1409 + return jdata
1446 1446  
1447 1447  end
1448 1448  
1449 ---send data
1413 +~-~-send data
1450 1450  
1451 1451  function send_Data()
1452 1452  
1453 - local pub_data =
1454 - {
1455 - 123
1456 - }
1417 + local pub_data =
1457 1457  
1419 + {
1420 +
1421 +123
1422 +
1423 +}
1424 +
1458 1458  sprint(json.encode(pub_data))
1459 1459  
1460 1460  print("..........",pub_RE_TOPIC)
1461 1461  
1462 - return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
1429 + return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
1463 1463  
1464 1464  end
1465 -{{/code}}
1466 1466  
1467 1467  Get message in AWS
1468 1468