Changes for page 2 Script

Last modified by Devin Chen on 2025/06/06 14:03

From 29.1 to 28.1 From 34.1 to 33.1

From version 33.1

edited by Hunter
on 2022/11/22 15:38

Change comment: There is no comment for this version

To version 29.1

edited by Hunter
on 2022/11/21 17:30

Change comment: There is no comment for this version

Raw
Rendered

Summary

Page properties (1 modified, 0 added, 0 removed)

Details

Page properties

Content

@@ -349,6 +349,7 @@
  end
  {{/code}}
++
  == **1.8 How to parse value from HTTP response body** ==
  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":
@@ -403,7 +403,7 @@
  {{/code}}
  (% class="wikigeneratedid" %)
--So we decode json into lua object to assign the value into addresses HDW6060(temperature), HDW7070(humidity), the code example like follows:
++So we decode json into lua object to assign the value into addresses HDW6060(temperature), HDW7070(humidity) the code example like follows:
  {{code language="lua"}}
  local APIkey = '70faaecf926b4341b1974006221711'
@@ -1156,20 +1156,35 @@
  {{code language="java"}}
  {
++
    "Version": "2012-10-17",
++
    "Statement": [
++
      {
++
        "Effect": "Allow",
++
        "Action": [
++
          "iot:Connect",
++
          "iot:Publish",
++
          "iot:Subscribe",
++
          "iot:Receive",
++
          "greengrass:Discover"
++
        ],
++
        "Resource": "*"
++
      }
++
    ]
++
  }
  {{/code}}
@@ -1234,186 +1234,185 @@
  [[image:image-20220709165402-20.png]]
--{{code language="lua"}}
  sprint = print
----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)
++~-~-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)
  local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg()
----publish to topics
++~-~-publish to topics
  local pub_RE_TOPIC = string.format('TEST')
----Subscribe topics
++~-~-Subscribe topics
  local Subscribe_RE_TOPIC1 = string.format('TEST')
----variable
++~-~-variable
  local last_time = 0
----Timing main function
++~-~-Timing main function
  function aws.main()
--            sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
++   sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
--            if g_mq then
++   if g_mq then
--                if g_mq:isconnected() then
++        if g_mq:isconnected() then
--                    send_Data()
++            send_Data()
--                else
++        else
--                if os.time() - last_time > 5 then
++            if os.time() - last_time > 5 then
--                    last_time = os.time()
++                last_time = os.time()
--                    mymqtt_connect()
++                mymqtt_connect()
--                end
--
              end
--            else
++        end
--                mymqtt_init()
++    else
--            end
++        mymqtt_init()
--            sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
++    end
++    sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
++
  end
++~-~- Initialize MQTT
---- Initialize MQTT
--
  function mymqtt_init()
--                sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
++    sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
--                g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) -- Create the object and declare it as a global variable
++    g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable
--                if g_mq then
++    if g_mq then
--                    g_mq:on("message", mymqtt_msg_callback) -- Register to receive message callbacks
++        g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks
--                    sprint("mqtt init success")
++        sprint("mqtt init success")
--                else
++    else
--                    sprint("mqtt init failed:", err)
++        sprint("mqtt init failed:", err)
--                end
++    end
  end
---- Connect to MQTT server
++~-~- Connect to MQTT server
  function mymqtt_connect()
--                sprint("mqtt connecting...")
++    sprint("mqtt connecting...")
--                local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
++    local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
--                if stat == nil then
++    if stat == nil then
--                    sprint("mqtt connect failed:", err)
++        sprint("mqtt connect failed:", err)
--                    return
++        return
--                else
++    else
--                    sprint("mqtt connected")
++        sprint("mqtt connected")
--                end
++    end
--                g_mq:subscribe(TEST, 0)
++    g_mq:subscribe(TEST, 0)
  end
---- Receive MQTT message callback function
++~-~- Receive MQTT message callback function
  function mymqtt_msg_callback(topic, msg)
--                print("topic:",topic)
++    print("topic:",topic)
--                print("revdata:",msg)
++    print("revdata:",msg)
--                local revData = json.decode(msg)
++    local revData = json.decode(msg)
--                print (revData)
++    print (revData)
--                if topic == Subscribe_RE_TOPIC1 then --Process topic information subscribed from the cloud
++ if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud
--                    if string.match(topic,Subscribe_RE_TOPIC1) then
++if string.match(topic,Subscribe_RE_TOPIC1) then
--                        --if revData ~= nil then
++    ~-~-if revData ~~= nil then
--                        for k,v in pairs (revData) do
++        for k,v in pairs (revData) do
--                            print("printing revdata after kv here")
++            print("printing revdata after kv here")
--                            print (k,v)
++            print (k,v)
--                        end
++        end
--                    print ("current state is",fanstate)
++        print ("current state is",fanstate)
--                        --end
++    ~-~-end
--                    end
++end
--                end
++end
  end
++~-~-Get real-time data
----Get real-time data
--
  function getData()
--                local jdata = {}
++    local jdata = {}
--                local addr = bns_get_alldata()
++    local addr = bns_get_alldata()
--                print(json.encode(addr))
++    print(json.encode(addr))
--                for i,v in pairs(addr) do
++    for i,v in pairs(addr) do
--                    if v[2] == 1 then
++        if v[2] == 1 then
--                        jdata[v[3]] = v[4]
++           jdata[v[3]] = v[4]
--                    end
++        end
--                end
++    end
--                return jdata
++    return jdata
  end
----send data
++~-~-send data
  function send_Data()
--                local pub_data =
--                {
--                    123
--                }
++    local pub_data =
++    {
++
++123
++
++}
++
  sprint(json.encode(pub_data))
  print("..........",pub_RE_TOPIC)
--                return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
++    return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
  end
--{{/code}}
  Get message in AWS

Changes for page 2 Script

Summary

Details

Navigation

Table of Contents