最细micropython接入阿里云，最易懂的上云指南

71 阅读 0 评论 47 点赞

我是靠谱客的博主干净蜜蜂，最近开发中收集的这篇文章主要介绍最细micropython接入阿里云，最易懂的上云指南，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

首先声明，本人致力于接单，所以自认为比较了解小白的心理和常犯的错误，我这里的教程肯定不是水平最高，最专业，但是应该是最容易让小白理解的。
遇到太多单子想接阿里云的了，或者说提到物联网平台，可能用到问的最多的就是阿里云，然而不是每个老板都有耐心按照阿里云文档重头学一遍，加上网上的大部分每个教程都很长，足矣劝退新手，而且有的地方是旧的文档内容，并不适用最新，本教程的截止日期是2020-5-14，亲测好用。
之前其实我比较排斥阿里云，感觉麻烦，之前用的onenet，但是后来onenet部分内容变收费了，使得心中好感度骤降，硬着头皮啃了一下阿里云，中间遇到几个坑，最终一路翻阅资料，最终费两天时间终于把全链路跑通了，撒花，下面正式开始教程：
1.准备工作
注册账号，这个是必要的，还是自己的东西心里有底，这里直接可参考其他人的教程，长，但是请耐心你看完。
这位博主是最细的：
完整上云教程
简要来说就是：
1.注册账号 2.进入物联网平台-控制台 3.创建产品并发布 4.创建设备
其实最终需要的数据无非就是如下五个：
clientId
username
passwd
mqttHostUrl
port
除了port固定是1883，其他的都是每个产品自己生成的，mqtt连接参数处有一个查看，可以一键赋值所有信息，会复制一个json数据包含这五个信息，我已经合并到代码里了，大家可以直接粘贴，不用一个一个去粘贴了。
有了这五个信息，结合micropython的mqtt就可以直接上云了。
还有两个是用到的
productkey
devicename
这俩是订阅mqtt主题的时候用到的，物联平台只接收他所规范的主题格式，其他的会报错，这里信息在设备里面容易找到
下面直接上代码：

import network,time
from simple import MQTTClient 
from machine import Pin,Timer
import ujson

info={"clientId":"gxspgXdzLKn.esp32|securemode=2,signmethod=hmacsha256,timestamp=1652535256081|","username":"esp32&gxspgXdzLKn","mqttHostUrl":"iot-06z00bab6ftg2fv.mqtt.iothub.aliyuncs.com","passwd":"c45cb175f56b851507439ca35428c4c45365c7a36f0f4a7960cbd0cf22d35802","port":1883}
productkey='gxspgXdzLKn'
devicename='esp32'
SSID='jd_asus'
WIFIPWD='800080008000'
subscribe_TOPIC='/sys/gxspgXdzLKn/esp32/thing/event/property/post_reply'
publish_TOPIC = '/sys/gxspgXdzLKn/esp32/thing/event/property/post'

def WIFI_Connect():

    WIFI_LED=Pin(2, Pin.OUT) #初始化WIFI指示灯

    wlan = network.WLAN(network.STA_IF) #STA模式
    wlan.active(True)                   #激活接口
    start_time=time.time()              #记录时间做超时判断

    if not wlan.isconnected():
        print('connecting to network...')
        wlan.connect(SSID, WIFIPWD) #输入WIFI账号密码

        while not wlan.isconnected():

            if time.time()-start_time > 15 :
                print('WIFI Connected Timeout!')
                break

    if wlan.isconnected():
        print('network information:', wlan.ifconfig())
        return True
    else:
        return False



def MQTT_callback(topic, msg):
    print('topic: {}'.format(topic))
    print('msg: {}'.format(msg))
    print('--------------------')
    command=ujson.loads(msg.decode())
    try:
        stopcode=command['params']['cloud_stop']
        if stopcode==0:
            print('云端控制开始')
        elif stopcode==1:
            print('云端控制停止')
    except:
        pass

def MQTT_Rev(tim):
    client.check_msg()
    
def MQTT_Publish(tim):
    mymessage='{"params": {"cloud_error":4}, "method": "thing.event.property.post"}'
    print(mymessage)
    client.publish(publish_TOPIC, mymessage,qos=0)
    client.check_msg()

if WIFI_Connect():
    
    client = MQTTClient(info["clientId"], info["mqttHostUrl"],info["port"],info["username"],info["passwd"]) #建立客户端对象
    client.set_callback(MQTT_callback)
    client.connect()
    client.subscribe(subscribe_TOPIC)
    mymessage='{"params": {"mymoney":30}, "method": "thing.event.property.post"}'
    print(mymessage)
    client.publish(publish_TOPIC, mymessage)

    tim = Timer(-1)
    tim.init(period=5000, mode=Timer.PERIODIC,callback=MQTT_Publish)

最后想说，micropython最常见的mqtt的simple.py居然还有坑，排除之后才能正常连接阿里云的Mqtt，有问题联系我吧。