腾讯云物联网平台使用报告

作者：三青时间：2023-06-11 阅读数：人阅读

前言：本文关于mqtt部分和前面两篇文章（硬件快速连接到阿里云物联网平台、ESP32 MQTT连接到中移OneNET物联网平台（附源码））大体相同，区别主要是腾讯云部分产品和设备的创建。

腾讯云创建产品和设备

1、物联网通信

2、创建产品

3、创建设备

产品列表---》设备列表---》添加新设备

4、设备信息

上面的client id 、mqtt usernme、mqtt password都是我们需要用到的。

除了上面3个参数，还需要知道Broker Address和Broker Port，根据腾讯官方的资料Broker Address和Broker Port分别是如下格式的：

Broker Address：PRODUCT_ID.iotcloud.tencentdevices.com

Broker Port:1883

5、订阅和发布主题

产品列表---》设备列表---》权限列表，可以看到如下3个主题：

MQTT.fx模拟设备接入

1、配置客户端

2、建立连接

3、订阅和发布主题

订阅成功之后，如下面的显示：

上报数据：Publish（发布）

腾讯云日志查看：

下发数据：设备列表---》点进相应的设备里面---》在线调试

客户端查看：

ESP32设备连接到腾讯云

1、创建产品

创建产品和设备、客户端参数的生成和上面一样的方法；创建一个温湿度上报到腾讯云的产品和设备。

2、MQTT库

ESP32需要使用到MQTT库，使用网上开源的umqtt：https://github.com/micropython/micropython-lib/blob/master/umqtt.simple/umqtt/simple.py需要把这个文件导入到ESP32中。

3、温湿度

MicroPython本身内置了dht模块，支持DHT11、DHT22。

4、硬件连接

VCC <------>3V3

GND<------>GND

DAT <------>G4

5、脚本编写

程序设计：定义了4个函数，ConnectWifi(ssid,passwd)用于连接wifi，ReadTemHum()用于读取温湿度，sub_cb(topic,msg)订阅主题回调，apptimerevent(mytimer)定时器回调函数。

from umqtt.simple import MQTTClientfrom machine import Pinimport networkimport timeimport machineimport dhtfrom machine import TimerSSID="*********"PASSWORD="**********"SERVER =LGSODS81VJ.iotcloud.tencentdevices.com #MQTT Server: LGSODS81VJ.iotcloud.tencentdevices.comCLIENT_ID = "LGSODS81VJESP32Devcice1" #设备ID#PORT=1883username=LGSODS81VJESP32Devcice1;12010126;C2PYL;1622167250password=ecd65158e4c9cdbfe48d116ca08ff069589f305936d8748fee269396207b01f8;hmacsha256publish_TOPIC = LGSODS81VJ/ESP32Devcice1/datasubscribe_TOPIC =LGSODS81VJ/ESP32Devcice1/dataclient=Nonemydht=Nonedef sub_cb(topic, msg): print((topic, msg))def connectWifi(ssid,passwd): global wlanwlan=network.WLAN(network.STA_IF) #create a wlan object wlan.active(True) #Activate the network interfacewlan.disconnect() #Disconnect the last connected WiFi wlan.connect(ssid,passwd) #connect wifiwhile(wlan.ifconfig()[0]==0.0.0.0): time.sleep(1) print(wlan.ifconfig())def apptimerevent(mytimer): try:sensordata=ReadTemHum() mymessage={"CurrentTemperature": %d ,"CurrentHumidity": %d }%(sensordata[0],sensordata[1])client.publish(topic=publish_TOPIC,msg= mymessage, retain=False, qos=0) except Exception as ex_results2:print(exception,ex_results2) mytimer.deinit()# finally:# machine.reset()# #Catch exceptions,stop program if interrupted accidentally in the trydef ReadTemHum(): mydht.measure() tem=mydht.temperature()hum=mydht.humidity() data=[tem,hum] print(data) return dataif __name__==__main__: try:mydht=dht.DHT11(machine.Pin(4)) connectWifi(SSID,PASSWORD)client = MQTTClient(CLIENT_ID, SERVER,0,username,password,60) #create a mqtt client print(client) client.set_callback(sub_cb) #set callbackclient.connect() #connect mqtt client.subscribe(subscribe_TOPIC) #client subscribes to a topic mytimer=Timer(0)mytimer.init(mode=Timer.PERIODIC, period=5000,callback=apptimerevent) while True: client.wait_msg() #wait messageexcept Exception as ex_results: print(exception1,ex_results) finally: if(client is not None):client.disconnect() wlan.disconnect() wlan.active(False)数据以JSON格式上传：mymessage={"CurrentTemperature": %d ,"CurrentHumidity": %d }%(sensordata[0],sensordata[1])

产品列表---》设备---》云日志---》内容日志---》可以查看上报的数据