HaaS Python

'''
ESP32开发板上board.json配置如下：
{
 "name": "esp32",
 "version": "1.0.0",
 "io": {
   "led": {
     "type": "GPIO",
     "port": 2,
     "dir": "output",
     "pull": "pullup"
   }
 },
 "debugLevel": "ERROR",
 "repl": "disable"
}
'''

# -*- coding: UTF-8 -*-

from aliyunIoT import Device     # iot组件是连接阿里云物联网平台的组件
import network                   # Wi-Fi功能所在库
import ujson                     # json字串解析库
import utime                     # 延时API所在组件
from driver import GPIO          # GPIO类，用于控制微处理器的输入输出功能

gpioledDev = 0

# 物联网平台连接标志位
iot_connected = False
wlan = None
# 三元组信息
productKey = "产品密钥"
deviceName = "设备名称"
deviceSecret = "设备密钥"

# 物联网设备实例
device = None

# Wi-Fi SSID和Password设置
wifiSsid = "请输入您的路由器名称"
wifiPassword = "请输入您的路由器密码"

# 等待Wi-Fi成功连接到路由器
def get_wifi_status():
  global wlan
  wifi_connected = False

  wlan.active(True)                  #激活界面
  wlan.scan()                        #扫描接入点
  #print("start to connect ", wifiSsid)
  wlan.connect(wifiSsid, wifiPassword)       # 连接到指定的路由器（路由器名称为wifiSsid, 密码为：wifiPassword）

  while True:
      wifi_connected = wlan.isconnected()    # 获取Wi-Fi连接路由器的状态信息
      if wifi_connected:                     # Wi-Fi连接成功则退出while循环
          break
      else:
          utime.sleep(0.5)
          print("wifi_connected:", wifi_connected)

  ifconfig = wlan.ifconfig()                    #获取接口的IP/netmask/gw/DNS地址
  print(ifconfig)
  utime.sleep(0.5)

# 物联网平台连接成功的回调函数
def on_connect(data):
  global iot_connected
  iot_connected = True

# 设置props 事件接收函数（当云平台向设备下发属性时）
def on_props(request):

  # {"ledSwitch":1} or {"ledSwitch":0}
  payload = ujson.loads(request['params'])

  # 获取dict状态字段 注意要验证键存在 否则会抛出异常
  if "ledSwitch" in payload.keys():
      print(payload)
      on = payload["ledSwitch"]

      if (on):
          led_control(1)
      else:
          led_control(0)

def connect_lk(productKey, deviceName, deviceSecret):
  global device, iot_connected
  key_info = {
      'region': 'cn-shanghai',
      'productKey': productKey,
      'deviceName': deviceName,
      'deviceSecret': deviceSecret,
      'keepaliveSec': 60
  }
  # 将三元组信息设置到iot组件中
  device = Device()

  # 设定连接到物联网平台的回调函数，如果连接物联网平台成功，则调用on_connect函数
  device.on(Device.ON_CONNECT, on_connect)

  # 配置收到云端属性控制指令的回调函数，如果收到物联网平台发送的属性控制消息，则调用on_props函数
  device.on(Device.ON_PROPS, on_props)

  # 启动连接阿里云物联网平台过程
  device.connect(key_info)

  # 等待设备成功连接到物联网平台
  while(True):
      if iot_connected:
          print('物联网平台连接成功')
          break
      else:
          print('sleep for 1 s')
          utime.sleep(1)
  print('sleep for 2s')
  utime.sleep(2)


def led_control(on):
  global gpioledDev
  if on == 0:
      gpioledDev.write(0)        # GPIO写入0，灭灯
  else:
      gpioledDev.write(1)        # GPIO写入1，亮灯

if __name__ == '__main__' :

  gpioledDev = GPIO()
  gpioledDev.open("led")

  wlan = network.WLAN(network.STA_IF)    #创建WLAN对象

  get_wifi_status()

  connect_lk(productKey, deviceName, deviceSecret)