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