quecpython提供了aLiYun( 阿里云物联网套件客户端功能) 和 TenCentYun(腾讯云物联网套件客户端功能), 可以非常方便的连接这两个云平台, 在真正使用umqtt库之前, 我们先了解一下这两个模块, 以便将来我们写出API风格类似的模块

---

第一部分 阿里云服务

一. aLiYun - 阿里云服务

阿里云物联网套件客户端功能,目前的产品节点类型仅支持“设备”，设备认证方式支持“一机一密和“一型一密”
关于阿里云IOT平台的设置, 我们不在赘述, 可参考之前的文章: https://www.jianshu.com/p/f0d46324a2c6

导入模块

from aLiYun import aLiYun

1. 实例化阿里云连接

aLiYun(productKey, productSecret, DeviceName, DeviceSecret)

我们要找到关键的三元组信息:

aLiYun模块这里多了一个productSecret , 此参数是为一型一密设计的, 如果是一机一密的方式,可以传None, 需要时也可按如下方式找到

2. 设置MQTT数据通道的参数

aLiYun.setMqtt(clientID, clean_session, keepAlive)

需要注意的是，当进行阿里云的一型一密连接的时候，会在本地生成secret.json的文件用以保存设备的设备密钥，如果重刷固件或者删除，再进行连接的时候会因为没有secret.json而报错，所以重刷固件或者删除了secert.json文件，需要手动新建secret.json文件，下面secret.json文件的模板

{
  "Test01": "9facf9aba414ec9eea7c10d8a4cb69a0"
}
# Test01 : 设备名
# "9facf9aba414ec9eea7c10d8a4cb69a0" 设备密钥

3.注册回调函数

aLiYun.setCallback(sub_cb)

4. 订阅mqtt主题

aLiYun.subscribe(topic,qos)

5. 发布消息

aLiYun.publish(topic,msg, qos=0)

6. 运行连接

aLiYun.start()

7. 关闭连接

aLiYun.disconnect()

二. 上传数据举例: 阿里云上传温湿度信息

from aLiYun import aLiYun
import ujson

PRODUCT_KEY = 'a1AYa96sZMJ'
PRODUCT_SECRET = None
DEVICE_NAME = 'EspTempAndHumi_D001'
DEVICE_SECRET = 'a23249cb179feee41ca2f8f38525113d'
aLiY = aLiYun(PRODUCT_KEY, PRODUCT_SECRET, DEVICE_NAME, DEVICE_SECRET)


state = 1
# 设备下发命令的set主题
ALINK_TOPIC_PROP_SET = "/sys/" + PRODUCT_KEY + \
    "/" + DEVICE_NAME + "/thing/service/property/set"
# 设备上传数据的post主题
ALINK_TOPIC_PROP_POST = "/sys/" + PRODUCT_KEY + \
    "/" + DEVICE_NAME + "/thing/event/property/post"
# 设备post上传数据要用到一个json字符串, 这个是拼接postJson用到的一个字符串
ALINK_METHOD_PROP_POST = "thing.event.property.post"


def sub_cb(topic, msg):
    global state
    print(
        "Subscribe Recv: Topic={},Msg={}".format(
            topic.decode(), msg.decode()))
    state -= 1


clientID = "testDevice"
aLiY.setMqtt(clientID, clean_session=False, keepAlive=300)

aLiY.setCallback(sub_cb)
aLiY.subscribe(ALINK_TOPIC_PROP_POST)

data_dict = {
    "CurrentTemperature": 24.3,
    "CurrentHumidity": 47.5,
    "GeoLocation": {
        "CoordinateSystem": 2,
        "Latitude": 36.11,
        "Longitude": 117.09,
        "Altitude": 150
    }
}
msg_dict = {
    "id": 1,
    "version": 1.0,
    "method": ALINK_METHOD_PROP_POST,
    "params": data_dict
}

aLiY.publish(ALINK_TOPIC_PROP_POST, ujson.dumps(msg_dict))
aLiY.start()
while True:
    if state:
        pass
    else:
        aLiY.disconnect()
        break

三. 下发命令举例: 远程控制灯开关

from aLiYun import aLiYun
import ujson
from machine import Timer

PRODUCT_KEY = 'a17lGhkKwXs'
PRODUCT_SECRET = None
DEVICE_NAME = 'esp32LightHome'
DEVICE_SECRET = '14fb77db62910b887dd28c5e449f406e'
aLiY = aLiYun(PRODUCT_KEY, PRODUCT_SECRET, DEVICE_NAME, DEVICE_SECRET)


# 设备下发命令的set主题
ALINK_TOPIC_PROP_SET = b"/sys/" + PRODUCT_KEY + \
    "/" + DEVICE_NAME + "/thing/service/property/set"
# 设备上传数据的post主题
ALINK_TOPIC_PROP_POST = b"/sys/" + PRODUCT_KEY + \
    "/" + DEVICE_NAME + "/thing/event/property/post"

light_status = 0

# 回调函数
def sub_cb(topic, msg):
    if topic == ALINK_TOPIC_PROP_POST:
        print(
            "上报成功! Subscribe Recv: Topic={},Msg={}".format(
                topic.decode(), msg.decode()))
    elif topic == ALINK_TOPIC_PROP_SET:
        print("下发成功! Subscribe Recv: Topic={},Msg={}".format(
            topic.decode(), msg.decode()))
        params = ujson.loads(msg.decode())['params']
        global light_status
        light_status = params["LightSwitch"]
        print("灯亮了" if light_status else "灯灭了")


clientID = "testDevice"  # 客户端ID,随便取名
aLiY.setMqtt(clientID, clean_session=False, keepAlive=300)  # 设置MQTT连接

aLiY.setCallback(sub_cb)  # 设置回调函数
aLiY.subscribe(ALINK_TOPIC_PROP_POST)  # 订阅上传数据主题


def send_msg_to_AliY(args):
    # 要上传的数据
    data_dict = {
        "LightSwitch": light_status
    }
    # 上传数据格式
    msg_dict = {
        "id": 1,
        "version": 1.0,
        "method": "thing.event.property.post",
        "params": data_dict
    }
    aLiY.publish(ALINK_TOPIC_PROP_POST, ujson.dumps(msg_dict))


timer1 = Timer(Timer.Timer1)
timer1.start(period=5000, mode=Timer.PERIODIC, callback=send_msg_to_AliY)
aLiY.start()
while True:
    pass

---

第二部分 腾讯云服务

腾讯云物联网套件客户端功能,目前的产品节点类型仅支持“设备”，设备认证方式支持“一机一密和“动态注册认证”。

from TenCentYun import TXyun

一. TenCentYun- 腾讯云服务

1. 实例化腾讯云服务

TXyun(productID, devicename, devicePsk, ProductSecret)

2. 设置MQTT数据通道的参数

TXyun.setMqtt(clean_session, keepAlive)

3. 注册回调函数

TXyun.setCallback(sub_cb)

4. 订阅mqtt主题

TXyun.subscribe(topic,qos=0)

5. 发布消息

TXyun.publish(topic,msg, qos=0)

6. 运行连接

TXyun.start()

7. 关闭连接

TXyun.disconnect()

二. 举例

现在看来, 腾讯云和阿里云IOT一毛一样, 直接参考阿里云的例子即可
此外, 我看腾讯云IOT文档, 好多是基于SDK介绍的, 而又没用提供micro-python SDK, 这就很尴尬了,腾讯云IOT我用的少, 但毕竟腾讯出品, 我相信她是很完善的平台。大家可以自行尝试。