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