Skip to Content

Changes for page 2 Script

Last modified by Devin Chen on 2025/06/06 14:03
From version 33.1
edited by Hunter
on 2022/11/22 15:38
Change comment: There is no comment for this version
To version 32.1
edited by Hunter
on 2022/11/22 14:09
Change comment: There is no comment for this version

Summary

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