Changes for page 2 Script

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