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 33.1
edited by Hunter
on 2022/11/22 15:38
Change comment: There is no comment for this version

Summary

Details

Page properties
Content
... ... @@ -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,186 @@
1249 1249  
1250 1250  [[image:image-20220709165402-20.png]]
1251 1251  
1237 +{{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)
1240 +--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
1244 +--publish to topics
1259 1259  
1260 1260  local pub_RE_TOPIC = string.format('TEST')
1261 1261  
1262 -~-~-Subscribe topics
1248 +--Subscribe topics
1263 1263  
1264 1264  local Subscribe_RE_TOPIC1 = string.format('TEST')
1265 1265  
1266 -~-~-variable
1252 +--variable
1267 1267  
1268 1268  local last_time = 0
1269 1269  
1270 -~-~-Timing main function
1256 +--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")
1260 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
1275 1275  
1276 - if g_mq then
1262 + if g_mq then
1277 1277  
1278 - if g_mq:isconnected() then
1264 + if g_mq:isconnected() then
1279 1279  
1280 - send_Data()
1266 + send_Data()
1281 1281  
1282 - else
1268 + else
1283 1283  
1284 - if os.time() - last_time > 5 then
1270 + if os.time() - last_time > 5 then
1285 1285  
1286 - last_time = os.time()
1272 + last_time = os.time()
1287 1287  
1288 - mymqtt_connect()
1274 + mymqtt_connect()
1289 1289  
1276 + end
1277 +
1290 1290   end
1291 1291  
1292 - end
1280 + else
1293 1293  
1294 - else
1282 + mymqtt_init()
1295 1295  
1296 - mymqtt_init()
1284 + end
1297 1297  
1298 - end
1286 + 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  
1292 +-- Initialize MQTT
1293 +
1307 1307  function mymqtt_init()
1308 1308  
1309 - sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
1296 + 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
1298 + g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) -- Create the object and declare it as a global variable
1312 1312  
1313 - if g_mq then
1300 + if g_mq then
1314 1314  
1315 - g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks
1302 + g_mq:on("message", mymqtt_msg_callback) -- Register to receive message callbacks
1316 1316  
1317 - sprint("mqtt init success")
1304 + sprint("mqtt init success")
1318 1318  
1319 - else
1306 + else
1320 1320  
1321 - sprint("mqtt init failed:", err)
1308 + sprint("mqtt init failed:", err)
1322 1322  
1323 - end
1310 + end
1324 1324  
1325 1325  end
1326 1326  
1327 -~-~- Connect to MQTT server
1314 +-- Connect to MQTT server
1328 1328  
1329 1329  function mymqtt_connect()
1330 1330  
1331 - sprint("mqtt connecting...")
1318 + sprint("mqtt connecting...")
1332 1332  
1333 - local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1320 + local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1334 1334  
1335 - if stat == nil then
1322 + if stat == nil then
1336 1336  
1337 - sprint("mqtt connect failed:", err)
1324 + sprint("mqtt connect failed:", err)
1338 1338  
1339 - return
1326 + return
1340 1340  
1341 - else
1328 + else
1342 1342  
1343 - sprint("mqtt connected")
1330 + sprint("mqtt connected")
1344 1344  
1345 - end
1332 + end
1346 1346  
1347 - g_mq:subscribe(TEST, 0)
1334 + g_mq:subscribe(TEST, 0)
1348 1348  
1349 1349  end
1350 1350  
1351 -~-~- Receive MQTT message callback function
1338 +-- Receive MQTT message callback function
1352 1352  
1353 1353  function mymqtt_msg_callback(topic, msg)
1354 1354  
1355 - print("topic:",topic)
1342 + print("topic:",topic)
1356 1356  
1357 - print("revdata:",msg)
1344 + print("revdata:",msg)
1358 1358  
1359 - local revData = json.decode(msg)
1346 + local revData = json.decode(msg)
1360 1360  
1361 - print (revData)
1348 + print (revData)
1362 1362  
1363 - if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud
1350 + if topic == Subscribe_RE_TOPIC1 then --Process topic information subscribed from the cloud
1364 1364  
1365 -if string.match(topic,Subscribe_RE_TOPIC1) then
1352 + if string.match(topic,Subscribe_RE_TOPIC1) then
1366 1366  
1367 - ~-~-if revData ~~= nil then
1354 + --if revData ~= nil then
1368 1368  
1369 - for k,v in pairs (revData) do
1356 + for k,v in pairs (revData) do
1370 1370  
1371 - print("printing revdata after kv here")
1358 + print("printing revdata after kv here")
1372 1372  
1373 - print (k,v)
1360 + print (k,v)
1374 1374  
1375 - end
1362 + end
1376 1376  
1377 - print ("current state is",fanstate)
1364 + print ("current state is",fanstate)
1378 1378  
1379 - ~-~-end
1366 + --end
1380 1380  
1381 -end
1368 + end
1382 1382  
1383 -end
1370 + end
1384 1384  
1385 1385  end
1386 1386  
1387 1387  
1388 -~-~-Get real-time data
1389 1389  
1376 +--Get real-time data
1377 +
1390 1390  function getData()
1391 1391  
1392 - local jdata = {}
1380 + local jdata = {}
1393 1393  
1394 - local addr = bns_get_alldata()
1382 + local addr = bns_get_alldata()
1395 1395  
1396 - print(json.encode(addr))
1384 + print(json.encode(addr))
1397 1397  
1398 - for i,v in pairs(addr) do
1386 + for i,v in pairs(addr) do
1399 1399  
1400 - if v[2] == 1 then
1388 + if v[2] == 1 then
1401 1401  
1402 - jdata[v[3]] = v[4]
1390 + jdata[v[3]] = v[4]
1403 1403  
1404 - end
1392 + end
1405 1405  
1406 - end
1394 + end
1407 1407  
1408 - return jdata
1396 + return jdata
1409 1409  
1410 1410  end
1411 1411  
1412 -~-~-send data
1400 +--send data
1413 1413  
1414 1414  function send_Data()
1415 1415  
1416 - local pub_data =
1404 + local pub_data =
1405 + {
1406 + 123
1407 + }
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)
1413 + return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
1429 1429  
1430 1430  end
1416 +{{/code}}
1431 1431  
1432 1432  Get message in AWS
1433 1433