Skip to Content

Changes for page 2 Script

Last modified by Devin Chen on 2025/06/06 14:03
From version 41.1
edited by Hunter
on 2023/03/17 18:05
Change comment: There is no comment for this version
To version 31.1
edited by Hunter
on 2022/11/22 09:47
Change comment: There is no comment for this version

Summary

Details

Page properties
Content
... ... @@ -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}}
468 +(% 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]]**
... ... @@ -474,25 +474,6 @@
474 474  
475 475  == **2.1 V-Box connect with test server(General Example)** ==
476 476  
477 -The following example is trying to publish to the topic "testtopic/test/no1/7890", and subscribe the topic "testtopic/test/no1/123456".
478 -
479 -And the JSON message is like follows:
480 -
481 -{{code language="JSON"}}
482 -{
483 - "timestamp": 1631152760,
484 - "messageId": 1,
485 - "event": "test_data",
486 - "mfrs": "HMI/box",
487 - "data":
488 - {
489 - "id" : 1436217747670454274,
490 - "waterlevel" : 48,
491 - "temperture" : 23
492 - }
493 -}
494 -{{/code}}
495 -
496 496  {{code language="lua"}}
497 497  --MQTT configuration table
498 498  local MQTT_CFG={}
... ... @@ -534,13 +534,9 @@
534 534  --initialize mqtt
535 535  function mqtt_init()
536 536   print(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENT_ID))
537 - if g_mq then
538 - mqtt.close() --Close mqtt object
539 - end
540 540   g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENT_ID) -- create mqtt object,and declare it as a global variable
541 541   if g_mq then
542 542   g_mq:on("message", mqtt_msg_callback) -- Register a callback for receiving messages
543 - g_mq:on("offline", mqtt_msg_offline) -- Register a callback for offline
544 544   print("mqtt init success")
545 545   else
546 546   print("mqtt init failed:", err)
... ... @@ -560,11 +560,6 @@
560 560   g_mq:subscribe(SUBSCRIBE_TOPIC, 0)
561 561  end
562 562  
563 ---Offline callback function
564 -function mqtt_msg_offline(cause)
565 - print("mqtt offline, cause:", cause)
566 -end
567 -
568 568  -- Received message callback function
569 569  function mqtt_msg_callback(topic, msg)
570 570   print("topic:", topic)
... ... @@ -603,11 +603,9 @@
603 603   if g_mq:isconnected() then
604 604   send_data()
605 605   else
606 - --if exceed 5 sec not connect, reconnect once
607 - if os.time() - LAST_TIME > 5 then
577 + --if exceed 20 sec not connect, reconnect once
578 + if os.time() - LAST_TIME > 20 then
608 608   LAST_TIME = os.time()
609 - --reinitial the mqtt object
610 - mqtt_init()
611 611   --connect to mqtt or reconnect
612 612   mqtt_connect()
613 613   end
... ... @@ -1187,20 +1187,35 @@
1187 1187  
1188 1188  {{code language="java"}}
1189 1189  {
1159 +
1190 1190    "Version": "2012-10-17",
1161 +
1191 1191    "Statement": [
1163 +
1192 1192      {
1165 +
1193 1193        "Effect": "Allow",
1167 +
1194 1194        "Action": [
1169 +
1195 1195          "iot:Connect",
1171 +
1196 1196          "iot:Publish",
1173 +
1197 1197          "iot:Subscribe",
1175 +
1198 1198          "iot:Receive",
1177 +
1199 1199          "greengrass:Discover"
1179 +
1200 1200        ],
1181 +
1201 1201        "Resource": "*"
1183 +
1202 1202      }
1185 +
1203 1203    ]
1187 +
1204 1204  }
1205 1205  {{/code}}
1206 1206  
... ... @@ -1265,190 +1265,185 @@
1265 1265  
1266 1266  [[image:image-20220709165402-20.png]]
1267 1267  
1268 -{{info}}
1269 -**✎Note:** Before using the following demo script, please make sure the V-Box firmware is newer than 22110701
1270 -{{/info}}
1271 -
1272 -{{code language="lua"}}
1273 1273  sprint = print
1274 1274  
1275 ---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)
1254 +~-~-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)
1276 1276  
1277 1277  local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg()
1278 1278  
1279 ---publish to topics
1258 +~-~-publish to topics
1280 1280  
1281 1281  local pub_RE_TOPIC = string.format('TEST')
1282 1282  
1283 ---Subscribe topics
1262 +~-~-Subscribe topics
1284 1284  
1285 1285  local Subscribe_RE_TOPIC1 = string.format('TEST')
1286 1286  
1287 ---variable
1266 +~-~-variable
1288 1288  
1289 1289  local last_time = 0
1290 1290  
1291 ---Timing main function
1270 +~-~-Timing main function
1292 1292  
1293 1293  function aws.main()
1294 1294  
1295 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
1274 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
1296 1296  
1297 - if g_mq then
1276 + if g_mq then
1298 1298  
1299 - if g_mq:isconnected() then
1278 + if g_mq:isconnected() then
1300 1300  
1301 - send_Data()
1280 + send_Data()
1302 1302  
1303 - else
1282 + else
1304 1304  
1305 - if os.time() - last_time > 5 then
1284 + if os.time() - last_time > 5 then
1306 1306  
1307 - last_time = os.time()
1286 + last_time = os.time()
1308 1308  
1309 - mymqtt_connect()
1288 + mymqtt_connect()
1310 1310  
1311 - end
1312 -
1313 1313   end
1314 1314  
1315 - else
1292 + end
1316 1316  
1317 - mymqtt_init()
1294 + else
1318 1318  
1319 - end
1296 + mymqtt_init()
1320 1320  
1321 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1298 + end
1322 1322  
1300 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1301 +
1323 1323  end
1324 1324  
1325 1325  
1305 +~-~- Initialize MQTT
1326 1326  
1327 --- Initialize MQTT
1328 -
1329 1329  function mymqtt_init()
1330 1330  
1331 - sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
1309 + sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
1332 1332  
1333 - 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
1311 + g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable
1334 1334  
1335 - if g_mq then
1313 + if g_mq then
1336 1336  
1337 - g_mq:on("message", mymqtt_msg_callback) -- Register to receive message callbacks
1315 + g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks
1338 1338  
1339 - sprint("mqtt init success")
1317 + sprint("mqtt init success")
1340 1340  
1341 - else
1319 + else
1342 1342  
1343 - sprint("mqtt init failed:", err)
1321 + sprint("mqtt init failed:", err)
1344 1344  
1345 - end
1323 + end
1346 1346  
1347 1347  end
1348 1348  
1349 --- Connect to MQTT server
1327 +~-~- Connect to MQTT server
1350 1350  
1351 1351  function mymqtt_connect()
1352 1352  
1353 - sprint("mqtt connecting...")
1331 + sprint("mqtt connecting...")
1354 1354  
1355 - local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1333 + local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1356 1356  
1357 - if stat == nil then
1335 + if stat == nil then
1358 1358  
1359 - sprint("mqtt connect failed:", err)
1337 + sprint("mqtt connect failed:", err)
1360 1360  
1361 - return
1339 + return
1362 1362  
1363 - else
1341 + else
1364 1364  
1365 - sprint("mqtt connected")
1343 + sprint("mqtt connected")
1366 1366  
1367 - end
1345 + end
1368 1368  
1369 - g_mq:subscribe(Subscribe_RE_TOPIC1, 0)
1347 + g_mq:subscribe(TEST, 0)
1370 1370  
1371 1371  end
1372 1372  
1373 --- Receive MQTT message callback function
1351 +~-~- Receive MQTT message callback function
1374 1374  
1375 1375  function mymqtt_msg_callback(topic, msg)
1376 1376  
1377 - print("topic:",topic)
1355 + print("topic:",topic)
1378 1378  
1379 - print("revdata:",msg)
1357 + print("revdata:",msg)
1380 1380  
1381 - local revData = json.decode(msg)
1359 + local revData = json.decode(msg)
1382 1382  
1383 - print (revData)
1361 + print (revData)
1384 1384  
1385 - if topic == Subscribe_RE_TOPIC1 then --Process topic information subscribed from the cloud
1363 + if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud
1386 1386  
1387 - if string.match(topic,Subscribe_RE_TOPIC1) then
1365 +if string.match(topic,Subscribe_RE_TOPIC1) then
1388 1388  
1389 - --if revData ~= nil then
1367 + ~-~-if revData ~~= nil then
1390 1390  
1391 - for k,v in pairs (revData) do
1369 + for k,v in pairs (revData) do
1392 1392  
1393 - print("printing revdata after kv here")
1371 + print("printing revdata after kv here")
1394 1394  
1395 - print (k,v)
1373 + print (k,v)
1396 1396  
1397 - end
1375 + end
1398 1398  
1399 - print ("current state is",fanstate)
1377 + print ("current state is",fanstate)
1400 1400  
1401 - --end
1379 + ~-~-end
1402 1402  
1403 - end
1381 +end
1404 1404  
1405 - end
1383 +end
1406 1406  
1407 1407  end
1408 1408  
1409 1409  
1388 +~-~-Get real-time data
1410 1410  
1411 ---Get real-time data
1412 -
1413 1413  function getData()
1414 1414  
1415 - local jdata = {}
1392 + local jdata = {}
1416 1416  
1417 - local addr = bns_get_alldata()
1394 + local addr = bns_get_alldata()
1418 1418  
1419 - print(json.encode(addr))
1396 + print(json.encode(addr))
1420 1420  
1421 - for i,v in pairs(addr) do
1398 + for i,v in pairs(addr) do
1422 1422  
1423 - if v[2] == 1 then
1400 + if v[2] == 1 then
1424 1424  
1425 - jdata[v[3]] = v[4]
1402 + jdata[v[3]] = v[4]
1426 1426  
1427 - end
1404 + end
1428 1428  
1429 - end
1406 + end
1430 1430  
1431 - return jdata
1408 + return jdata
1432 1432  
1433 1433  end
1434 1434  
1435 ---send data
1412 +~-~-send data
1436 1436  
1437 1437  function send_Data()
1438 1438  
1439 - local pub_data =
1440 - {
1441 - 123
1442 - }
1416 + local pub_data =
1443 1443  
1418 + {
1419 +
1420 +123
1421 +
1422 +}
1423 +
1444 1444  sprint(json.encode(pub_data))
1445 1445  
1446 1446  print("..........",pub_RE_TOPIC)
1447 1447  
1448 - return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
1428 + return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
1449 1449  
1450 1450  end
1451 -{{/code}}
1452 1452  
1453 1453  Get message in AWS
1454 1454