11、确保已安装python3.7，理论上3.x的应该都行，我没有用虚拟环境
22、pip install paho-mqtt==1.4.0
33、pip install aliyun-iot-linkkit

  1import sys
  2from linkkit import linkkit
  3import threading
  4import traceback
  5import inspect
  6import time
  7import logging
  8import json
  9import random
 10import datetime 
 11 
 12#功能打开设备二维码需要用到python下的窗口界面控件
 13#import pyqrcode,tkinter
 14#from tkinter.messagebox import *
 15 
 16 
 17# config log
 18__log_format = '%(asctime)s-%(process)d-%(thread)d - %(name)s:%(module)s:%(funcName)s - %(levelname)s - %(message)s'
 19logging.basicConfig(format=__log_format)
 20 
 21#这里需要填写你的相关参数
 22host_name="cn-shanghai"
 23product_key="hml6xxxx"
 24device_name="ROhLixxxxxxxxxxxxxxxxxx"
 25device_secret="98ca62xxxxxxxxxxxxxxxxxxxxxxxxxxxx"
 26 
 27#默认的payload，便于后续处理发布上报payload使用
 28data_pubCommandResult_ori = {
 29"pubType":2,
 30"configInfo":"",
 31"status":0,
 32"user":"nSC1XiB",
 33"sTimes":1,
 34"serialNumber":round(time.time()*1000)
 35}
 36data_start = {
 37"clickNumbers":2,
 38"cardNum":"nSC1XiB",
 39"serialNumber":20230627110463
 40}
 41 
 42def equ_setting(write=''):#write=空表示读取内容
 43    if write=='':
 44        try:
 45            f=open('ali_mqtt.ini','r+')
 46            equ_setting=json.loads(f.read())
 47            f.close
 48        except Exception :
 49            print('配置文件错误，重新初始化')  
 50            f=open('ali_mqtt.ini','w')
 51            f.write('{"a":1}')
 52            f.close  
 53            equ_setting={"a":1}
 54    else:
 55        try:
 56            f=open('ali_mqtt.ini','w')
 57            f.write(write)
 58            f.close  
 59            equ_setting=json.loads(write)
 60        except Exception :
 61            print('配置文件错误，更新失败')
 62            #print(write)
 63            f=open('ali_mqtt.ini','r+')
 64            equ_setting=json.loads(f.read())
 65            f.close
 66    return equ_setting
 67 
 68 
 69 
 70lk = linkkit.LinkKit(
 71    host_name=host_name,
 72    product_key=product_key,
 73    device_name=device_name,
 74    device_secret=device_secret)
 75#lk.config_mqtt(endpoint=product_key+".iot-as-mqtt.cn-shanghai.aliyuncs.com")#公共阿里云物联网实例一般可以不要这一行
 76lk.config_mqtt(port=1883, protocol="MQTTv311", transport="TCP",
 77            secure="TLS", keep_alive=60, clean_session=True,
 78            max_inflight_message=20, max_queued_message=0,
 79            auto_reconnect_min_sec=1,
 80            auto_reconnect_max_sec=60,
 81            cadata=None)
 82#开启/关闭日志
 83lk.enable_logger(logging.DEBUG)
 84 
 85 
 86def on_device_dynamic_register(rc, value, userdata):
 87    if rc == 0:
 88        print("dynamic register device success, value:" + value)
 89    else:
 90        print("dynamic register device fail, message:" + value)
 91 
 92 
 93def on_connect(session_flag, rc, userdata):
 94    print("on_connect:%d,rc:%d" % (session_flag, rc))
 95    #阿里云官方aliyun-iot-linkkit提供的sdk在lk.to_full_topic()里面不需要填写topic的/productkey/devicename，我这里的topic不是/user/test 是user/pubStart
 96    #官方解释：lk.to_full_topic是一个Topic自动生成接口，您在前面已经填入了ProductKey、DeviceName等参数，该接口调用后将返回一个字符串，其值等同于"/YourProductKey/YourDeviceName/user/test"
 97    rc, mid = lk.publish_topic(lk.to_full_topic("user/pubStart"), '这里是需要上报的paylod，一般约定是json格式，也可以是这种字符串')
 98    if rc == 0:
 99         print("===========================设备启动，发布获取配置topic成功:%r, mid:%r" % (rc, mid))
100    else:
101        print("===========================设备启动，发布获取配置topic失败:%d" % rc)
102    print("="*45)
103    print("提示，请输入以下清单对应序号！")
104    tips()
105    pass
106 
107 
108def on_disconnect(rc, userdata):
109    print("on_disconnect:rc:%d,userdata:" % rc)
110 
111 
112def on_topic_message(topic, payload, qos, userdata):
113    #必须先确保已经订阅了相关topic，否则这里收不到
114    print("===================开始接受订阅消息===========================")
115    #
116    print("on_topic_message:" + topic + " payload:" + str(payload) + " qos:" + str(qos))
117    print("=================订阅消息已接收完毕===========================")
118 
119    #根据接收到的订阅消息的topic进行判断，并处理相关逻辑；；；；
120    payload=json.loads(payload)#payload是消息内容，需要json序列化一下方便使用
121    if 'user/subConfig' in topic:#订阅到设备参数的topic，需要把订阅消息的内容存入本地文件（约定的都是json格式的）
122        equ_setting(json.dumps(payload))
123        #print("已订阅到服务器下发的卡头参数"+equ_setting(''))
124 
125    if 'user/subCommand' in topic:#订阅到的topic是 服务器下发的指令需求，根据订阅消息的operateType参数决定客户端进行下一步操作
126        if payload['operateType']==3:#3订阅到的消息是要上报设备状态
127            data_pubCommandResult=data_pubCommandResult_ori# 为了防止变量被其他topic更新，每次上报的内容都需要先用默认的变量进行复制而不是直接使用默认变量
128            if payload['sTimes']==4:#如果sTimes是4，客户端随机返回 上报status=0或1
129                print("===========================随机上报设备状态")
130                data_pubCommandResult['serialNumber']=payload['serialNumber']#将要上报的serialNumber取自 订阅到的消息里的serialNumber
131                data_pubCommandResult['user']=payload['user']
132                data_pubCommandResult['sTimes']=payload['sTimes']
133                data_pubCommandResult['status']=random.randint(0,1)# 0正常 1异常
134                rc, mid = lk.publish_topic(lk.to_full_topic("user/pubCommandResult"), json.dumps(data_pubCommandResult))
135                if rc == 0:
136                    print("===========================发布设备状态成功【status="+str(data_pubCommandResult['status'])+"】" )
137                
138                else:
139                    print("===========================发布设备状态失败:%d" % rc)
140            else:
141                #其他处理逻辑代码类似，不再赘述
142                pass
143        else:
144            #其他处理逻辑代码类似，不再赘述
145            pass
146    pass
147 
148 
149def on_subscribe_topic(mid, granted_qos, userdata):
150    #granted_qos 为订阅topic列表对应的QoS返回结果，正常值为0或1，128表示订阅失败
151    print("函数内>>>>on_subscribe_topic mid:%d, granted_qos:%s" %
152          (mid, str(','.join('%s' % it for it in granted_qos))))
153    pass
154 
155 
156def on_unsubscribe_topic(mid, userdata):
157    print("on_unsubscribe_topic mid:%d" % mid)
158    pass
159 
160 
161def on_publish_topic(mid, userdata):
162    print("on_publish_topic mid:%d" % mid)
163 
164 
165def tips():
166 
167    print("1、模拟启动2次")
168    print("2、查看设备配置参数")
169    print("3、打开设备二维码")
170    print("")
171    print("="*45)
172def clicked():
173    num=txt.get()  
174    #直接上报一条消息 启动
175    rc, mid = lk.publish_topic(lk.to_full_topic("user/pubStart"), '这里是需要上报的paylod，一般约定是json格式，也可以是这种字符串')
176    if rc == 0:
177        showinfo("提示", "启动"+num+"次成功")
178        print("===========================按键启动topic发送成功")
179    else:
180        showerror("提示", "启动"+num+"次失败")
181        print("===========================按键启动topic发送失败:%d" % rc)
182    
183lk.on_device_dynamic_register = on_device_dynamic_register
184lk.on_connect = on_connect
185lk.on_disconnect = on_disconnect
186lk.on_topic_message = on_topic_message
187lk.on_subscribe_topic = on_subscribe_topic
188lk.on_unsubscribe_topic = on_unsubscribe_topic
189lk.on_publish_topic = on_publish_topic
190 
191 
192lk.config_device_info("Eth|03ACDEFF0032|Eth|03ACDEFF0031")#这里是阿里云sdk默认的，没做修改
193lk.connect_async()
194lk.start_worker_loop()
195 
196while True:
197    
198    try:
199        msg = input()
200    except KeyboardInterrupt:
201        sys.exit()
202    else:
203        if msg == "close":
204            lk.disconnect()
205        elif msg == "start":
206            lk.connect_async()
207 
208        elif msg == "1":
209            #直接上报一条消息 启动
210            data_start['serialNumber']=round(time.time()*1000)+999
211 
212 
213            data_start['clickNumbers']=2
214            rc, mid = lk.publish_topic(lk.to_full_topic("user/pubStart"), json.dumps(data_start))
215            if rc == 0:
216                print("===========================模拟启动topic发送成功【次数="+str(data_start['clickNumbers'])+"】")
217            else:
218                print("===========================模拟启动topic发送失败:%d" % rc)
219 
220        elif msg=="2":
221                print(json.dumps(equ_setting('')))
222 
223        elif msg=="3":
224                print("示例已关闭")
225                '''
226                code=pyqrcode.create("hell 123456-asdfghj")#如需要显示中文encoding='UTF-8'即可        
227                cXbm=code.xbm(scale=5)#scale生成的二维码图片比例大小
228 
229                win=tkinter.Tk()
230                win.title("二维码")
231                tkBap=tkinter.BitmapImage(data=cXbm)
232                tkBap.config(foreground="black")
233                tkBap.config(background="white")
234                tLable=tkinter.Label(image=tkBap)
235                tLable.grid(column=0, row=0)               
236                tLable2=tkinter.Label(text="==================")
237                txt = tkinter.Entry( width=4)
238                txt.insert(0,"2")
239                btn = tkinter.Button(text=" 启动 ",command=clicked)
240                tLable3=tkinter.Label(text="启动次数->")
241                tLable.pack()
242                tLable2.pack(fill=tkinter.X)
243                
244                btn.pack(fill=tkinter.Y,side=tkinter.RIGHT,pady='10px',padx='5px')
245                txt.pack(fill=tkinter.Y,side=tkinter.RIGHT,pady='10px',padx='5px')
246                tLable3.pack(fill=tkinter.Y,side=tkinter.RIGHT,pady='10px')
247                '''
248                pass
249 
250 
251        elif msg == "A": # 订阅消息，一般只需要订阅一次，后面再启动客户端不需要再订阅，除非操作了取消请阅
252            rc, mid = lk.subscribe_topic(lk.to_full_topic("user/subComman"))
253            if rc == 0:
254                print("===========================subscribe topic success:%r, mid:%r" % (rc, mid))
255            else:
256                print("===========================subscribe topic fail:%d" % rc)
257        elif msg == "B":# 订阅消息，一般只需要订阅一次，后面再启动客户端不需要再订阅，除非操作了取消请阅
258            rc, mid = lk.subscribe_topic(lk.to_full_topic("user/subConfig"))
259            if rc == 0:
260                print("===========================subscribe topic success:%r, mid:%r" % (rc, mid))
261            else:
262                print("===========================subscribe topic fail:%d" % rc)
263 
264 
265 
266        elif msg == "dump":
267            ret = lk.dump_user_topics()
268            print("user topics:%s", str(ret))
269        elif msg == "dest":
270            lk.destruct()
271            print("destructed")
272        else:
273            print("="*45)
274            print("指令错误，请输入以下清单对应序号！")
275            tips()
276            #sys.exit()