阿里云飞燕点灯（Linkkit-python）_阿里飞燕点灯

Link Kit SDK是阿里云物联网平台提供的设备端软件开发工具包，可简化开发过程，实现无硬件接入阿里云物联网平台。

---

## 环境搭建 1. 系统需要搭载python版本3.3及以上版本。 [python官网下载](https://www.python.org/) 2. 打开windows命令行，创建python虚拟环境。 ``` mkdir env_demo cd env_demo python -m venv test_env ``` 3. 这时在刚刚创建的文档env_demo会有虚拟环境配置文件test_env，进一步激活 python虚拟环境。 ``` test_env\Scripts\activate.bat ``` 此时命令行会进入python虚拟环境（前面会有虚拟环境名称作为前缀）。 

4. 用pip在虚拟环境下安装所需要的库paho-mqqt和aliyun-iot-linkkit。

   pip install paho-mqtt==1.4.0
   pip install aliyun-iot-linkkit
   1
   2

创建并运行

1. 在虚拟环文件下创建一个py文件。
   
2. 打开创建的py文件，并将代码拷入。

   import sys
   from linkkit import linkkit
   import logging
   
   # config log
   __log_format = '%(asctime)s-%(process)d-%(thread)d - %(name)s:%(module)s:%(funcName)s - %(levelname)s - %(message)s'
   logging.basicConfig(format=__log_format)
   
   lk = linkkit.LinkKit(
       host_name="cn-shanghai",
       product_key="product_key",
       device_name="device_name",
       device_secret="device_secret",
       product_secret="product_secret")
   
   lk.enable_logger(logging.DEBUG)
   
   
   def on_device_dynamic_register(rc, value, userdata):
       if rc == 0:
           print("dynamic register device success, rc:%d, value:%s" % (rc, value))
       else:
           print("dynamic register device fail,rc:%d, value:%s" % (rc, value))
   
   
   def on_connect(session_flag, rc, userdata):
       print("on_connect:%d,rc:%d,userdata:" % (session_flag, rc))
       pass
   
   
   def on_disconnect(rc, userdata):
       print("on_disconnect:rc:%d,userdata:" % rc)
   
   
   def on_topic_message(topic, payload, qos, userdata):
       print("on_topic_message:" + topic + " payload:" + str(payload) + " qos:" + str(qos))
       pass
   
   
   def on_subscribe_topic(mid, granted_qos, userdata):
       print("on_subscribe_topic mid:%d, granted_qos:%s" %
             (mid, str(','.join('%s' % it for it in granted_qos))))
       pass
   
   
   def on_unsubscribe_topic(mid, userdata):
       print("on_unsubscribe_topic mid:%d" % mid)
       pass
   
   
   def on_publish_topic(mid, userdata):
       print("on_publish_topic mid:%d" % mid)
   
   
   lk.on_device_dynamic_register = on_device_dynamic_register
   lk.on_connect = on_connect
   lk.on_disconnect = on_disconnect
   lk.on_topic_message = on_topic_message
   lk.on_subscribe_topic = on_subscribe_topic
   lk.on_unsubscribe_topic = on_unsubscribe_topic
   lk.on_publish_topic = on_publish_topic
   lk.connect_async()
   
   
   while True:
       try:
           msg = input()
       except KeyboardInterrupt:
           sys.exit()
       else:
           if msg == "1":
               lk.disconnect()
           elif msg == "2":
               lk.connect_async()
           else:
               sys.exit()
   1
   2
   3
   4
   5
   6
   7
   8
   9
   10
   11
   12
   13
   14
   15
   16
   17
   18
   19
   20
   21
   22
   23
   24
   25
   26
   27
   28
   29
   30
   31
   32
   33
   34
   35
   36
   37
   38
   39
   40
   41
   42
   43
   44
   45
   46
   47
   48
   49
   50
   51
   52
   53
   54
   55
   56
   57
   58
   59
   60
   61
   62
   63
   64
   65
   66
   67
   68
   69
   70
   71
   72
   73
   74
   75
   76

3. 更换代码中三元组的信息至你的产品信息。
   
4. 已经开启的虚拟环境的命令行中，运行此程序。

   python example.py
   1

   成功连接上设备，阿里云产品显示在线。