首先声明,本人致力于接单,所以自认为比较了解小白的心理和常犯的错误,我这里的教程肯定不是水平最高,最专业,但是应该是最容易让小白理解的。 遇到太多单子想接阿里云的了,或者说提到物联网平台,可能用到问的最多的就是阿里云,然而不是每个老板都有耐心按照阿里云文档重头学一遍,加上网上的大部分每个教程都很长,足矣劝退新手,而且有的地方是旧的文档内容,并不适用最新,本教程的截止日期是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,有问题联系我吧。
|