Skip to Content

Changes for page 2 Script

Last modified by Devin Chen on 2025/06/06 14:03
From version 30.1
edited by Hunter
on 2022/11/21 17:31
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
... ... @@ -349,7 +349,6 @@
349 349  end
350 350  {{/code}}
351 351  
352 -
353 353  == **1.8 How to parse value from HTTP response body** ==
354 354  
355 355  This example use [[https:~~/~~/www.weatherapi.com/>>https://www.weatherapi.com/]] as example, to show how to parse value from HTTP response body. When we input the city name into address "@HDW5050":
... ... @@ -1157,35 +1157,20 @@
1157 1157  
1158 1158  {{code language="java"}}
1159 1159  {
1160 -
1161 1161    "Version": "2012-10-17",
1162 -
1163 1163    "Statement": [
1164 -
1165 1165      {
1166 -
1167 1167        "Effect": "Allow",
1168 -
1169 1169        "Action": [
1170 -
1171 1171          "iot:Connect",
1172 -
1173 1173          "iot:Publish",
1174 -
1175 1175          "iot:Subscribe",
1176 -
1177 1177          "iot:Receive",
1178 -
1179 1179          "greengrass:Discover"
1180 -
1181 1181        ],
1182 -
1183 1183        "Resource": "*"
1184 -
1185 1185      }
1186 -
1187 1187    ]
1188 -
1189 1189  }
1190 1190  {{/code}}
1191 1191  
... ... @@ -1250,185 +1250,186 @@
1250 1250  
1251 1251  [[image:image-20220709165402-20.png]]
1252 1252  
1237 +{{code language="lua"}}
1253 1253  sprint = print
1254 1254  
1255 -~-~-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)
1256 1256  
1257 1257  local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg()
1258 1258  
1259 -~-~-publish to topics
1244 +--publish to topics
1260 1260  
1261 1261  local pub_RE_TOPIC = string.format('TEST')
1262 1262  
1263 -~-~-Subscribe topics
1248 +--Subscribe topics
1264 1264  
1265 1265  local Subscribe_RE_TOPIC1 = string.format('TEST')
1266 1266  
1267 -~-~-variable
1252 +--variable
1268 1268  
1269 1269  local last_time = 0
1270 1270  
1271 -~-~-Timing main function
1256 +--Timing main function
1272 1272  
1273 1273  function aws.main()
1274 1274  
1275 - 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")
1276 1276  
1277 - if g_mq then
1262 + if g_mq then
1278 1278  
1279 - if g_mq:isconnected() then
1264 + if g_mq:isconnected() then
1280 1280  
1281 - send_Data()
1266 + send_Data()
1282 1282  
1283 - else
1268 + else
1284 1284  
1285 - if os.time() - last_time > 5 then
1270 + if os.time() - last_time > 5 then
1286 1286  
1287 - last_time = os.time()
1272 + last_time = os.time()
1288 1288  
1289 - mymqtt_connect()
1274 + mymqtt_connect()
1290 1290  
1276 + end
1277 +
1291 1291   end
1292 1292  
1293 - end
1280 + else
1294 1294  
1295 - else
1282 + mymqtt_init()
1296 1296  
1297 - mymqtt_init()
1284 + end
1298 1298  
1299 - end
1286 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1300 1300  
1301 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
1302 -
1303 1303  end
1304 1304  
1305 1305  
1306 -~-~- Initialize MQTT
1307 1307  
1292 +-- Initialize MQTT
1293 +
1308 1308  function mymqtt_init()
1309 1309  
1310 - 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))
1311 1311  
1312 - 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
1313 1313  
1314 - if g_mq then
1300 + if g_mq then
1315 1315  
1316 - 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
1317 1317  
1318 - sprint("mqtt init success")
1304 + sprint("mqtt init success")
1319 1319  
1320 - else
1306 + else
1321 1321  
1322 - sprint("mqtt init failed:", err)
1308 + sprint("mqtt init failed:", err)
1323 1323  
1324 - end
1310 + end
1325 1325  
1326 1326  end
1327 1327  
1328 -~-~- Connect to MQTT server
1314 +-- Connect to MQTT server
1329 1329  
1330 1330  function mymqtt_connect()
1331 1331  
1332 - sprint("mqtt connecting...")
1318 + sprint("mqtt connecting...")
1333 1333  
1334 - 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)
1335 1335  
1336 - if stat == nil then
1322 + if stat == nil then
1337 1337  
1338 - sprint("mqtt connect failed:", err)
1324 + sprint("mqtt connect failed:", err)
1339 1339  
1340 - return
1326 + return
1341 1341  
1342 - else
1328 + else
1343 1343  
1344 - sprint("mqtt connected")
1330 + sprint("mqtt connected")
1345 1345  
1346 - end
1332 + end
1347 1347  
1348 - g_mq:subscribe(TEST, 0)
1334 + g_mq:subscribe(TEST, 0)
1349 1349  
1350 1350  end
1351 1351  
1352 -~-~- Receive MQTT message callback function
1338 +-- Receive MQTT message callback function
1353 1353  
1354 1354  function mymqtt_msg_callback(topic, msg)
1355 1355  
1356 - print("topic:",topic)
1342 + print("topic:",topic)
1357 1357  
1358 - print("revdata:",msg)
1344 + print("revdata:",msg)
1359 1359  
1360 - local revData = json.decode(msg)
1346 + local revData = json.decode(msg)
1361 1361  
1362 - print (revData)
1348 + print (revData)
1363 1363  
1364 - 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
1365 1365  
1366 -if string.match(topic,Subscribe_RE_TOPIC1) then
1352 + if string.match(topic,Subscribe_RE_TOPIC1) then
1367 1367  
1368 - ~-~-if revData ~~= nil then
1354 + --if revData ~= nil then
1369 1369  
1370 - for k,v in pairs (revData) do
1356 + for k,v in pairs (revData) do
1371 1371  
1372 - print("printing revdata after kv here")
1358 + print("printing revdata after kv here")
1373 1373  
1374 - print (k,v)
1360 + print (k,v)
1375 1375  
1376 - end
1362 + end
1377 1377  
1378 - print ("current state is",fanstate)
1364 + print ("current state is",fanstate)
1379 1379  
1380 - ~-~-end
1366 + --end
1381 1381  
1382 -end
1368 + end
1383 1383  
1384 -end
1370 + end
1385 1385  
1386 1386  end
1387 1387  
1388 1388  
1389 -~-~-Get real-time data
1390 1390  
1376 +--Get real-time data
1377 +
1391 1391  function getData()
1392 1392  
1393 - local jdata = {}
1380 + local jdata = {}
1394 1394  
1395 - local addr = bns_get_alldata()
1382 + local addr = bns_get_alldata()
1396 1396  
1397 - print(json.encode(addr))
1384 + print(json.encode(addr))
1398 1398  
1399 - for i,v in pairs(addr) do
1386 + for i,v in pairs(addr) do
1400 1400  
1401 - if v[2] == 1 then
1388 + if v[2] == 1 then
1402 1402  
1403 - jdata[v[3]] = v[4]
1390 + jdata[v[3]] = v[4]
1404 1404  
1405 - end
1392 + end
1406 1406  
1407 - end
1394 + end
1408 1408  
1409 - return jdata
1396 + return jdata
1410 1410  
1411 1411  end
1412 1412  
1413 -~-~-send data
1400 +--send data
1414 1414  
1415 1415  function send_Data()
1416 1416  
1417 - local pub_data =
1404 + local pub_data =
1405 + {
1406 + 123
1407 + }
1418 1418  
1419 - {
1420 -
1421 -123
1422 -
1423 -}
1424 -
1425 1425  sprint(json.encode(pub_data))
1426 1426  
1427 1427  print("..........",pub_RE_TOPIC)
1428 1428  
1429 - 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)
1430 1430  
1431 1431  end
1416 +{{/code}}
1432 1432  
1433 1433  Get message in AWS
1434 1434