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