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 39.1
edited by Hunter
on 2023/03/17 15:50
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":
... ... @@ -466,8 +466,9 @@
466 466  
467 467  (% class="mark" %)2.If your server requires SSL certificate to log in,please use OpenCloud.Because only OpenCloud platform can support to upload certificate
468 468  
469 -(% class="wikigeneratedid" %)
468 +{{info}}
470 470  **✎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,9 +515,13 @@
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
518 518   g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENT_ID) -- create mqtt object,and declare it as a global variable
519 519   if g_mq then
520 520   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
521 521   print("mqtt init success")
522 522   else
523 523   print("mqtt init failed:", err)
... ... @@ -575,9 +575,11 @@
575 575   if g_mq:isconnected() then
576 576   send_data()
577 577   else
578 - --if exceed 20 sec not connect, reconnect once
579 - if os.time() - LAST_TIME > 20 then
582 + --if exceed 5 sec not connect, reconnect once
583 + if os.time() - LAST_TIME > 5 then
580 580   LAST_TIME = os.time()
585 + --reinitial the mqtt object
586 + mqtt_init()
581 581   --connect to mqtt or reconnect
582 582   mqtt_connect()
583 583   end
... ... @@ -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,190 @@
1250 1250  
1251 1251  [[image:image-20220709165402-20.png]]
1252 1252  
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"}}
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)
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)
1256 1256  
1257 1257  local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg()
1258 1258  
1259 -~-~-publish to topics
1255 +--publish to topics
1260 1260  
1261 1261  local pub_RE_TOPIC = string.format('TEST')
1262 1262  
1263 -~-~-Subscribe topics
1259 +--Subscribe topics
1264 1264  
1265 1265  local Subscribe_RE_TOPIC1 = string.format('TEST')
1266 1266  
1267 -~-~-variable
1263 +--variable
1268 1268  
1269 1269  local last_time = 0
1270 1270  
1271 -~-~-Timing main function
1267 +--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")
1271 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
1276 1276  
1277 - if g_mq then
1273 + if g_mq then
1278 1278  
1279 - if g_mq:isconnected() then
1275 + if g_mq:isconnected() then
1280 1280  
1281 - send_Data()
1277 + send_Data()
1282 1282  
1283 - else
1279 + else
1284 1284  
1285 - if os.time() - last_time > 5 then
1281 + if os.time() - last_time > 5 then
1286 1286  
1287 - last_time = os.time()
1283 + last_time = os.time()
1288 1288  
1289 - mymqtt_connect()
1285 + mymqtt_connect()
1290 1290  
1287 + end
1288 +
1291 1291   end
1292 1292  
1293 - end
1291 + else
1294 1294  
1295 - else
1293 + mymqtt_init()
1296 1296  
1297 - mymqtt_init()
1295 + end
1298 1298  
1299 - end
1297 + 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  
1303 +-- Initialize MQTT
1304 +
1308 1308  function mymqtt_init()
1309 1309  
1310 - sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
1307 + 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
1309 + g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID, 1) -- Create the object and declare it as a global variable, 1 means using the domain to connect
1313 1313  
1314 - if g_mq then
1311 + if g_mq then
1315 1315  
1316 - g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks
1313 + g_mq:on("message", mymqtt_msg_callback) -- Register to receive message callbacks
1317 1317  
1318 - sprint("mqtt init success")
1315 + sprint("mqtt init success")
1319 1319  
1320 - else
1317 + else
1321 1321  
1322 - sprint("mqtt init failed:", err)
1319 + sprint("mqtt init failed:", err)
1323 1323  
1324 - end
1321 + end
1325 1325  
1326 1326  end
1327 1327  
1328 -~-~- Connect to MQTT server
1325 +-- Connect to MQTT server
1329 1329  
1330 1330  function mymqtt_connect()
1331 1331  
1332 - sprint("mqtt connecting...")
1329 + sprint("mqtt connecting...")
1333 1333  
1334 - local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1331 + local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
1335 1335  
1336 - if stat == nil then
1333 + if stat == nil then
1337 1337  
1338 - sprint("mqtt connect failed:", err)
1335 + sprint("mqtt connect failed:", err)
1339 1339  
1340 - return
1337 + return
1341 1341  
1342 - else
1339 + else
1343 1343  
1344 - sprint("mqtt connected")
1341 + sprint("mqtt connected")
1345 1345  
1346 - end
1343 + end
1347 1347  
1348 - g_mq:subscribe(TEST, 0)
1345 + g_mq:subscribe(Subscribe_RE_TOPIC1, 0)
1349 1349  
1350 1350  end
1351 1351  
1352 -~-~- Receive MQTT message callback function
1349 +-- Receive MQTT message callback function
1353 1353  
1354 1354  function mymqtt_msg_callback(topic, msg)
1355 1355  
1356 - print("topic:",topic)
1353 + print("topic:",topic)
1357 1357  
1358 - print("revdata:",msg)
1355 + print("revdata:",msg)
1359 1359  
1360 - local revData = json.decode(msg)
1357 + local revData = json.decode(msg)
1361 1361  
1362 - print (revData)
1359 + print (revData)
1363 1363  
1364 - if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud
1361 + if topic == Subscribe_RE_TOPIC1 then --Process topic information subscribed from the cloud
1365 1365  
1366 -if string.match(topic,Subscribe_RE_TOPIC1) then
1363 + if string.match(topic,Subscribe_RE_TOPIC1) then
1367 1367  
1368 - ~-~-if revData ~~= nil then
1365 + --if revData ~= nil then
1369 1369  
1370 - for k,v in pairs (revData) do
1367 + for k,v in pairs (revData) do
1371 1371  
1372 - print("printing revdata after kv here")
1369 + print("printing revdata after kv here")
1373 1373  
1374 - print (k,v)
1371 + print (k,v)
1375 1375  
1376 - end
1373 + end
1377 1377  
1378 - print ("current state is",fanstate)
1375 + print ("current state is",fanstate)
1379 1379  
1380 - ~-~-end
1377 + --end
1381 1381  
1382 -end
1379 + end
1383 1383  
1384 -end
1381 + end
1385 1385  
1386 1386  end
1387 1387  
1388 1388  
1389 -~-~-Get real-time data
1390 1390  
1387 +--Get real-time data
1388 +
1391 1391  function getData()
1392 1392  
1393 - local jdata = {}
1391 + local jdata = {}
1394 1394  
1395 - local addr = bns_get_alldata()
1393 + local addr = bns_get_alldata()
1396 1396  
1397 - print(json.encode(addr))
1395 + print(json.encode(addr))
1398 1398  
1399 - for i,v in pairs(addr) do
1397 + for i,v in pairs(addr) do
1400 1400  
1401 - if v[2] == 1 then
1399 + if v[2] == 1 then
1402 1402  
1403 - jdata[v[3]] = v[4]
1401 + jdata[v[3]] = v[4]
1404 1404  
1405 - end
1403 + end
1406 1406  
1407 - end
1405 + end
1408 1408  
1409 - return jdata
1407 + return jdata
1410 1410  
1411 1411  end
1412 1412  
1413 -~-~-send data
1411 +--send data
1414 1414  
1415 1415  function send_Data()
1416 1416  
1417 - local pub_data =
1415 + local pub_data =
1416 + {
1417 + 123
1418 + }
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)
1424 + return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
1430 1430  
1431 1431  end
1427 +{{/code}}
1432 1432  
1433 1433  Get message in AWS
1434 1434