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)
-
Attachments (0 modified, 0 added, 1 removed)
Details
- Page properties
-
- Content
-
... ... @@ -349,104 +349,6 @@ 349 349 end 350 350 {{/code}} 351 351 352 -== **1.8 How to parse value from HTTP response body** == 353 - 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": 355 - 356 -(% style="text-align:center" %) 357 -[[image:InputHTTPparameter.png]] 358 - 359 -Then the response body would be like as following: 360 - 361 -{{code language="json"}} 362 -{ 363 - "location": { 364 - "name": "Madrid", 365 - "region": "Madrid", 366 - "country": "Spain", 367 - "lat": 40.4, 368 - "lon": -3.68, 369 - "tz_id": "Europe/Madrid", 370 - "localtime_epoch": 1669022636, 371 - "localtime": "2022-11-21 10:23" 372 - }, 373 - "current": { 374 - "last_updated_epoch": 1669022100, 375 - "last_updated": "2022-11-21 10:15", 376 - "temp_c": 13.0, 377 - "temp_f": 55.4, 378 - "is_day": 1, 379 - "condition": { 380 - "text": "Partly cloudy", 381 - "icon": "//cdn.weatherapi.com/weather/64x64/day/116.png", 382 - "code": 1003 383 - }, 384 - "wind_mph": 11.9, 385 - "wind_kph": 19.1, 386 - "wind_degree": 210, 387 - "wind_dir": "SSW", 388 - "pressure_mb": 1015.0, 389 - "pressure_in": 29.97, 390 - "precip_mm": 0.0, 391 - "precip_in": 0.0, 392 - "humidity": 88, 393 - "cloud": 75, 394 - "feelslike_c": 10.8, 395 - "feelslike_f": 51.4, 396 - "vis_km": 10.0, 397 - "vis_miles": 6.0, 398 - "uv": 3.0, 399 - "gust_mph": 22.1, 400 - "gust_kph": 35.6 401 - } 402 -} 403 -{{/code}} 404 - 405 -(% class="wikigeneratedid" %) 406 -So we decode json into lua object to assign the value into addresses HDW6060(temperature), HDW7070(humidity), the code example like follows: 407 - 408 -{{code language="lua"}} 409 -local APIkey = '70faaecf926b4341b1974006221711' 410 - 411 - 412 -local http = require("socket.http") 413 -local json = require("json") 414 - 415 --- Send http.get request and return response result 416 -function getHttpsUrl(url) 417 - local result_table, code, headers, status = http.request(url) 418 - print("code:"..code) 419 - if code~= 200 then 420 - return 421 - else 422 - return result_table 423 - end 424 -end 425 - 426 -function sendAPI(key, city) 427 - local url = "http://api.weatherapi.com/v1/current.json?key="..key.."&q="..city.."&aqi=no" 428 - --local url = 'http://v-box.net' 429 - --local url = 'https://www.google.com/' 430 - --http://api.weatherapi.com/v1/current.json?key=70faaecf926b4341b1974006221711&q=Barcelona&aqi=no 431 - print("Get the link:"..url) 432 - local body = getHttpsUrl(url) 433 - --print(body) 434 - local jsonBody = json.decode(body) 435 - --print(jsonBody["current"]["temp_c"]) 436 - --print(type(jsonBody["current"]["temp_c"])) 437 - --print(type(jsonBody["current"]["humidity"])) 438 - addr_setfloat("@HDW6060", jsonBody["current"]["temp_c"]) 439 - addr_setword("@HDW7070", jsonBody["current"]["humidity"]) 440 -end 441 - 442 - 443 -function Weather.main() 444 - local cityName = addr_getstring("@HDW5050",6) 445 - print("cityName: "..cityName) 446 - sendAPI(APIkey, cityName) 447 -end 448 -{{/code}} 449 - 450 450 = **2 V-Box connect with third part server** = 451 451 452 452 V-Box have two mode.One is for V-Net,User need to use WECON server to store data.We call this V-NET platform. ... ... @@ -1156,20 +1156,35 @@ 1156 1156 1157 1157 {{code language="java"}} 1158 1158 { 1061 + 1159 1159 "Version": "2012-10-17", 1063 + 1160 1160 "Statement": [ 1065 + 1161 1161 { 1067 + 1162 1162 "Effect": "Allow", 1069 + 1163 1163 "Action": [ 1071 + 1164 1164 "iot:Connect", 1073 + 1165 1165 "iot:Publish", 1075 + 1166 1166 "iot:Subscribe", 1077 + 1167 1167 "iot:Receive", 1079 + 1168 1168 "greengrass:Discover" 1081 + 1169 1169 ], 1083 + 1170 1170 "Resource": "*" 1085 + 1171 1171 } 1087 + 1172 1172 ] 1089 + 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) 1156 +~-~-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 1160 +~-~-publish to topics 1245 1245 1246 1246 local pub_RE_TOPIC = string.format('TEST') 1247 1247 1248 ---Subscribe topics 1164 +~-~-Subscribe topics 1249 1249 1250 1250 local Subscribe_RE_TOPIC1 = string.format('TEST') 1251 1251 1252 ---variable 1168 +~-~-variable 1253 1253 1254 1254 local last_time = 0 1255 1255 1256 ---Timing main function 1172 +~-~-Timing main function 1257 1257 1258 1258 function aws.main() 1259 1259 1260 - 1176 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start") 1261 1261 1262 - 1178 + if g_mq then 1263 1263 1264 - 1180 + if g_mq:isconnected() then 1265 1265 1266 - 1182 + send_Data() 1267 1267 1268 - 1184 + else 1269 1269 1270 - 1186 + if os.time() - last_time > 5 then 1271 1271 1272 - 1188 + last_time = os.time() 1273 1273 1274 - 1190 + mymqtt_connect() 1275 1275 1276 - end 1277 - 1278 1278 end 1279 1279 1280 - lse1194 + end 1281 1281 1282 - mymqtt_init()1196 + else 1283 1283 1284 - end1198 + mymqtt_init() 1285 1285 1286 - sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.mainend")1200 + end 1287 1287 1202 + sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end") 1203 + 1288 1288 end 1289 1289 1290 1290 1207 +~-~- Initialize MQTT 1291 1291 1292 --- Initialize MQTT 1293 - 1294 1294 function mymqtt_init() 1295 1295 1296 - 1211 + sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID)) 1297 1297 1298 - 1213 + g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable 1299 1299 1300 - 1215 + if g_mq then 1301 1301 1302 - 1217 + g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks 1303 1303 1304 - 1219 + sprint("mqtt init success") 1305 1305 1306 - 1221 + else 1307 1307 1308 - 1223 + sprint("mqtt init failed:", err) 1309 1309 1310 - 1225 + end 1311 1311 1312 1312 end 1313 1313 1314 --- Connect to MQTT server 1229 +~-~- Connect to MQTT server 1315 1315 1316 1316 function mymqtt_connect() 1317 1317 1318 - 1233 + sprint("mqtt connecting...") 1319 1319 1320 - 1235 + local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART) 1321 1321 1322 - 1237 + if stat == nil then 1323 1323 1324 - 1239 + sprint("mqtt connect failed:", err) 1325 1325 1326 - 1241 + return 1327 1327 1328 - 1243 + else 1329 1329 1330 - 1245 + sprint("mqtt connected") 1331 1331 1332 - 1247 + end 1333 1333 1334 - Subscribe_RE_TOPIC1, 0)1249 + g_mq:subscribe(TEST, 0) 1335 1335 1336 1336 end 1337 1337 1338 --- Receive MQTT message callback function 1253 +~-~- Receive MQTT message callback function 1339 1339 1340 1340 function mymqtt_msg_callback(topic, msg) 1341 1341 1342 - 1257 + print("topic:",topic) 1343 1343 1344 - 1259 + print("revdata:",msg) 1345 1345 1346 - 1261 + local revData = json.decode(msg) 1347 1347 1348 - 1263 + print (revData) 1349 1349 1350 - 1265 + if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud 1351 1351 1352 - 1267 +if string.match(topic,Subscribe_RE_TOPIC1) then 1353 1353 1354 - 1269 + ~-~-if revData ~~= nil then 1355 1355 1356 - 1271 + for k,v in pairs (revData) do 1357 1357 1358 - 1273 + print("printing revdata after kv here") 1359 1359 1360 - 1275 + print (k,v) 1361 1361 1362 - 1277 + end 1363 1363 1364 - 1279 + print ("current state is",fanstate) 1365 1365 1366 - 1281 + ~-~-end 1367 1367 1368 - 1283 +end 1369 1369 1370 - 1285 +end 1371 1371 1372 1372 end 1373 1373 1374 1374 1290 +~-~-Get real-time data 1375 1375 1376 ---Get real-time data 1377 - 1378 1378 function getData() 1379 1379 1380 - 1294 + local jdata = {} 1381 1381 1382 - 1296 + local addr = bns_get_alldata() 1383 1383 1384 - 1298 + print(json.encode(addr)) 1385 1385 1386 - 1300 + for i,v in pairs(addr) do 1387 1387 1388 - 1302 + if v[2] == 1 then 1389 1389 1390 - 1304 + jdata[v[3]] = v[4] 1391 1391 1392 - 1306 + end 1393 1393 1394 - 1308 + end 1395 1395 1396 - 1310 + return jdata 1397 1397 1398 1398 end 1399 1399 1400 ---send data 1314 +~-~-send data 1401 1401 1402 1402 function send_Data() 1403 1403 1404 - local pub_data = 1405 - { 1406 - 123 1407 - } 1318 + local pub_data = 1408 1408 1320 + { 1321 + 1322 +123 1323 + 1324 +} 1325 + 1409 1409 sprint(json.encode(pub_data)) 1410 1410 1411 1411 print("..........",pub_RE_TOPIC) 1412 1412 1413 - 1330 + 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
- InputHTTPparameter.png
-
- Author
-
... ... @@ -1,1 +1,0 @@ 1 -XWiki.Hunter - Size
-
... ... @@ -1,1 +1,0 @@ 1 -17.9 KB - Content