Skip to Content

Changes for page 2 Script

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

Summary

Details

Page properties
Content
... ... @@ -465,8 +465,9 @@
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 -(% class="wikigeneratedid" %)
468 +{{info}}
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}}
470 470  
471 471  (% class="wikigeneratedid" %)
472 472  Tool link: **[[MQTT.fx>>http://mqttfx.jensd.de/index.php/download]]**
... ... @@ -514,9 +514,13 @@
514 514  --initialize mqtt
515 515  function mqtt_init()
516 516   print(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENT_ID))
518 + if g_mq then
519 + mqtt.close() --Close mqtt object
520 + end
517 517   g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENT_ID) -- create mqtt object,and declare it as a global variable
518 518   if g_mq then
519 519   g_mq:on("message", mqtt_msg_callback) -- Register a callback for receiving messages
524 + g_mq:on("offline", mqtt_msg_offline) -- Register a callback for offline
520 520   print("mqtt init success")
521 521   else
522 522   print("mqtt init failed:", err)
... ... @@ -536,6 +536,11 @@
536 536   g_mq:subscribe(SUBSCRIBE_TOPIC, 0)
537 537  end
538 538  
544 +--Offline callback function
545 +function mqtt_msg_offline(cause)
546 + print("mqtt offline, cause:", cause)
547 +end
548 +
539 539  -- Received message callback function
540 540  function mqtt_msg_callback(topic, msg)
541 541   print("topic:", topic)
... ... @@ -574,9 +574,11 @@
574 574   if g_mq:isconnected() then
575 575   send_data()
576 576   else
577 - --if exceed 20 sec not connect, reconnect once
578 - if os.time() - LAST_TIME > 20 then
587 + --if exceed 5 sec not connect, reconnect once
588 + if os.time() - LAST_TIME > 5 then
579 579   LAST_TIME = os.time()
590 + --reinitial the mqtt object
591 + mqtt_init()
580 580   --connect to mqtt or reconnect
581 581   mqtt_connect()
582 582   end
... ... @@ -1156,35 +1156,20 @@
1156 1156  
1157 1157  {{code language="java"}}
1158 1158  {
1159 -
1160 1160    "Version": "2012-10-17",
1161 -
1162 1162    "Statement": [
1163 -
1164 1164      {
1165 -
1166 1166        "Effect": "Allow",
1167 -
1168 1168        "Action": [
1169 -
1170 1170          "iot:Connect",
1171 -
1172 1172          "iot:Publish",
1173 -
1174 1174          "iot:Subscribe",
1175 -
1176 1176          "iot:Receive",
1177 -
1178 1178          "greengrass:Discover"
1179 -
1180 1180        ],
1181 -
1182 1182        "Resource": "*"
1183 -
1184 1184      }
1185 -
1186 1186    ]
1187 -
1188 1188  }
1189 1189  {{/code}}
1190 1190  
... ... @@ -1249,185 +1249,190 @@
1249 1249  
1250 1250  [[image:image-20220709165402-20.png]]
1251 1251  
1249 +{{info}}
1250 +**✎Note:** Before using the following demo script, please make sure the V-Box firmware is newer than 22110701
1251 +{{/info}}
1252 +
1253 +{{code language="lua"}}
1252 1252  sprint = print
1253 1253  
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)
1256 +--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 1255  
1256 1256  local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg()
1257 1257  
1258 -~-~-publish to topics
1260 +--publish to topics
1259 1259  
1260 1260  local pub_RE_TOPIC = string.format('TEST')
1261 1261  
1262 -~-~-Subscribe topics
1264 +--Subscribe topics
1263 1263  
1264 1264  local Subscribe_RE_TOPIC1 = string.format('TEST')
1265 1265  
1266 -~-~-variable
1268 +--variable
1267 1267  
1268 1268  local last_time = 0
1269 1269  
1270 -~-~-Timing main function
1272 +--Timing main function
1271 1271  
1272 1272  function aws.main()
1273 1273  
1274 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
1276 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
1275 1275  
1276 - if g_mq then
1278 + if g_mq then
1277 1277  
1278 - if g_mq:isconnected() then
1280 + if g_mq:isconnected() then
1279 1279  
1280 - send_Data()
1282 + send_Data()
1281 1281  
1282 - else
1284 + else
1283 1283  
1284 - if os.time() - last_time > 5 then
1286 + if os.time() - last_time > 5 then
1285 1285  
1286 - last_time = os.time()
1288 + last_time = os.time()
1287 1287  
1288 - mymqtt_connect()
1290 + mymqtt_connect()
1289 1289  
1292 + end
1293 +
1290 1290   end
1291 1291  
1292 - end
1296 + else
1293 1293  
1294 - else
1298 + mymqtt_init()
1295 1295  
1296 - mymqtt_init()
1300 + end
1297 1297  
1298 - end
1302 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1299 1299  
1300 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1301 -
1302 1302  end
1303 1303  
1304 1304  
1305 -~-~- Initialize MQTT
1306 1306  
1308 +-- Initialize MQTT
1309 +
1307 1307  function mymqtt_init()
1308 1308  
1309 - sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
1312 + sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
1310 1310  
1311 - g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable
1314 + 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 1312  
1313 - if g_mq then
1316 + if g_mq then
1314 1314  
1315 - g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks
1318 + g_mq:on("message", mymqtt_msg_callback) -- Register to receive message callbacks
1316 1316  
1317 - sprint("mqtt init success")
1320 + sprint("mqtt init success")
1318 1318  
1319 - else
1322 + else
1320 1320  
1321 - sprint("mqtt init failed:", err)
1324 + sprint("mqtt init failed:", err)
1322 1322  
1323 - end
1326 + end
1324 1324  
1325 1325  end
1326 1326  
1327 -~-~- Connect to MQTT server
1330 +-- Connect to MQTT server
1328 1328  
1329 1329  function mymqtt_connect()
1330 1330  
1331 - sprint("mqtt connecting...")
1334 + sprint("mqtt connecting...")
1332 1332  
1333 - local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1336 + local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1334 1334  
1335 - if stat == nil then
1338 + if stat == nil then
1336 1336  
1337 - sprint("mqtt connect failed:", err)
1340 + sprint("mqtt connect failed:", err)
1338 1338  
1339 - return
1342 + return
1340 1340  
1341 - else
1344 + else
1342 1342  
1343 - sprint("mqtt connected")
1346 + sprint("mqtt connected")
1344 1344  
1345 - end
1348 + end
1346 1346  
1347 - g_mq:subscribe(TEST, 0)
1350 + g_mq:subscribe(Subscribe_RE_TOPIC1, 0)
1348 1348  
1349 1349  end
1350 1350  
1351 -~-~- Receive MQTT message callback function
1354 +-- Receive MQTT message callback function
1352 1352  
1353 1353  function mymqtt_msg_callback(topic, msg)
1354 1354  
1355 - print("topic:",topic)
1358 + print("topic:",topic)
1356 1356  
1357 - print("revdata:",msg)
1360 + print("revdata:",msg)
1358 1358  
1359 - local revData = json.decode(msg)
1362 + local revData = json.decode(msg)
1360 1360  
1361 - print (revData)
1364 + print (revData)
1362 1362  
1363 - if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud
1366 + if topic == Subscribe_RE_TOPIC1 then --Process topic information subscribed from the cloud
1364 1364  
1365 -if string.match(topic,Subscribe_RE_TOPIC1) then
1368 + if string.match(topic,Subscribe_RE_TOPIC1) then
1366 1366  
1367 - ~-~-if revData ~~= nil then
1370 + --if revData ~= nil then
1368 1368  
1369 - for k,v in pairs (revData) do
1372 + for k,v in pairs (revData) do
1370 1370  
1371 - print("printing revdata after kv here")
1374 + print("printing revdata after kv here")
1372 1372  
1373 - print (k,v)
1376 + print (k,v)
1374 1374  
1375 - end
1378 + end
1376 1376  
1377 - print ("current state is",fanstate)
1380 + print ("current state is",fanstate)
1378 1378  
1379 - ~-~-end
1382 + --end
1380 1380  
1381 -end
1384 + end
1382 1382  
1383 -end
1386 + end
1384 1384  
1385 1385  end
1386 1386  
1387 1387  
1388 -~-~-Get real-time data
1389 1389  
1392 +--Get real-time data
1393 +
1390 1390  function getData()
1391 1391  
1392 - local jdata = {}
1396 + local jdata = {}
1393 1393  
1394 - local addr = bns_get_alldata()
1398 + local addr = bns_get_alldata()
1395 1395  
1396 - print(json.encode(addr))
1400 + print(json.encode(addr))
1397 1397  
1398 - for i,v in pairs(addr) do
1402 + for i,v in pairs(addr) do
1399 1399  
1400 - if v[2] == 1 then
1404 + if v[2] == 1 then
1401 1401  
1402 - jdata[v[3]] = v[4]
1406 + jdata[v[3]] = v[4]
1403 1403  
1404 - end
1408 + end
1405 1405  
1406 - end
1410 + end
1407 1407  
1408 - return jdata
1412 + return jdata
1409 1409  
1410 1410  end
1411 1411  
1412 -~-~-send data
1416 +--send data
1413 1413  
1414 1414  function send_Data()
1415 1415  
1416 - local pub_data =
1420 + local pub_data =
1421 + {
1422 + 123
1423 + }
1417 1417  
1418 - {
1419 -
1420 -123
1421 -
1422 -}
1423 -
1424 1424  sprint(json.encode(pub_data))
1425 1425  
1426 1426  print("..........",pub_RE_TOPIC)
1427 1427  
1428 - 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)
1429 1429  
1430 1430  end
1432 +{{/code}}
1431 1431  
1432 1432  Get message in AWS
1433 1433