(2)用Micropython将ESP32数据上云

importnetworkimportutimeWIFISSID="Put your ssid here"WIFIPWD="Put yuou ssid password"wlan=NoneclassConnectWIFI:
defconnect_wifi(self): 
# network.STA_IF 站点也称为客户端，连接到上游WiFi接入点# network.AP_IF 作为热点，允许其他WiFi客户端接入。热点模式允许用户将自己的设备配置为热点，这让多个设备之间的无线连接在不借助外部路由器网络的情况下成为可能。wlan=network.WLAN(network.STA_IF)  
wifi_connected=Falsewlan.active(True)                  
wlan.scan()                         
wlan.connect(WIFISSID, WIFIPWD)       # 定义好的SSID 和 密码whileTrue:
# 判断是否已经连接网络wifi_connected=wlan.isconnected()    
ifwifi_connected:                     
# 若没有连接成功，则一直连接breakelse:
# 连接成功，进行提示utime.sleep_ms(2000)
print("Wifi connet status :", wifi_connected)
ifconfig=wlan.ifconfig()       
# 打印网络情况              print(ifconfig)

importutimeimportujsonfromaliyunIoTimportDevicefromexample.haas_ledimportHAASLediot_connected=Falsedevice=None# 物联网平台连接成功的回调函数 defon_connect( data):
print('on_connect')
globaliot_connectediot_connected=Truedefon_props(request): 
led_entity=HAASLed()
led_entity.handle_iot_data(request) 
classHaasIOT(object):
defreport_data(self, data):
globaldeviceupload_data= {'params': ujson.dumps(data)
        } 
device.postProps(upload_data) 
defconnect_iot(self):
self.test()
globaldevice, iot_connectedkey_info= {
'region': 'cn-shanghai',
'productKey': 'XXX', 
'deviceName': 'XXX',
'deviceSecret': 'XXX',
'keepaliveSec': 60        } 
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):
ifiot_connected:
print('物联网平台连接成功')
breakelse:
print('sleep for 1 s')
utime.sleep(1)
print('sleep for 2s')
utime.sleep(2)

if__name__=='__main__': 
wifi_entity=ConnectWIFI()
wifi_connected=wifi_entity.connect_wifi()
ifwifi_connectedisTrue:   
hass_iot_entity=HaasIOT()
hass_iot_entity.connect_iot()

defon_props(request): 
led_entity=HAASLed()
led_entity.handle_iot_data(request)

defhandle_iot_data(self, rsp): 
print(type(rsp))
print(rsp) # {'code': 0, 'params_len': 20, 'msg_id': 659157818, 'params': '{"led_red_switch":0}'}ifrsp.get('code') ==0:
data=rsp.get('params') 
led_switch=ujson.loads(data)  # '{"led_red_switch":1}'led_red_switch=led_switch.get('led_red_switch') 
ifled_red_switchisnotNone:
self.control_led("led_red_switch", led_red_switch)
led_green_switch=led_switch.get('led_green_switch') 
ifled_green_switchisnotNone:
self.control_led("led_green_switch", led_green_switch)
led_yellow_switch=led_switch.get('led_yellow_switch') 
ifled_yellow_switchisnotNone:
self.control_led("led_yellow_switch", led_yellow_switch)
defcontrol_led(self,led, status):
r_led_gpio=GPIO()
y_led_gpio=GPIO()
g_led_gpio=GPIO()
r_led_gpio.open("r_led")
y_led_gpio.open("y_led")
g_led_gpio.open("g_led")
ifled=="led_red_switch":
r_led_gpio.write(status)
elifled=="led_green_switch":
g_led_gpio.write(status)
elifled=="led_yellow_switch":
y_led_gpio.write(status)

defreport_data(self, data):
globaldeviceupload_data= {'params': ujson.dumps(data)
        } 
device.postProps(upload_data)