CheckNetwork

  1. '''
  2. 下面两个全局变量是必须有的，用户可以根据自己的实际项目修改下面两个全局变量的值
  3. '''
  4. PROJECT_NAME = "QuecPython_AliYin_example"
  5. PROJECT_VERSION = "1.0.0"
  6. checknet = checkNet.CheckNetwork(PROJECT_NAME, PROJECT_VERSION)
  8. stagecode, subcode = checknet.wait_network_connected(30)

demo

  2. import log
  3. import utime
  4. import checkNet
  5. from aLiYun import aLiYun
  7. '''
  8. 下面两个全局变量是必须有的，用户可以根据自己的实际项目修改下面两个全局变量的值
  9. '''
  10. PROJECT_NAME = "QuecPython_AliYin_example"
  11. PROJECT_VERSION = "1.0.0"
  12. checknet = checkNet.CheckNetwork(PROJECT_NAME, PROJECT_VERSION)
  15. # 设置日志输出级别
  16. log.basicConfig(level=log.INFO)
  17. aliYun_log = log.getLogger("ALiYun")
  19. productKey = ""  # 产品标识(参照阿里 IoT 平台应用开发指导)
  20. productSecret = None  # 产品密钥（使用一机一密认证时此参数传入None，参照阿里 IoT 平台应用开发指导)
  21. DeviceName = ""  # 设备名称(参照阿里 IoT 平台应用开发指导)
  22. DeviceSecret = ""  # 设备密钥（使用一型一密认证此参数传入None，免预注册暂不支持，需先在 IoT 平台创建设备，参照阿里 IoT 平台应用开发指导)
  24. state = 5
  26. # 回调函数
  27. def sub_cb(topic, msg):
  28.     global state
  29.     aliYun_log.info("Subscribe Recv: Topic={},Msg={}".format(topic.decode(), msg.decode()))
  30.     state -= 1
  33. if __name__ == '__main__':
  34.     stagecode, subcode = checknet.wait_network_connected(30)
  35.     if stagecode == 3 and subcode == 1:
  36.         aliYun_log.info('Network connection successful!')
  37.         # 创建aliyun连接对象
  38.         ali = aLiYun(productKey, productSecret, DeviceName, DeviceSecret)
  40.         # 设置mqtt连接属性
  41.         clientID = ""  # 自定义字符（不超过64）
  42.         ali.setMqtt(clientID, clean_session=False, keepAlive=300)
  44.         # 设置回调函数
  45.         ali.setCallback(sub_cb)
  46.         topic = ""  # IoT 平台自定义或自拥有的Topic
  47.         # 订阅主题
  48.         ali.subscribe(topic)
  49.         # 发布消息
  50.         ali.publish(topic, "hello world")
  51.         # 运行
  52.         ali.start()
  54.         while 1:
  55.             if state:
  56.                 pass
  57.             else:
  58.                 ali.disconnect()
  59.                 break
  60.     else:
  61.         aliYun_log.info('Network connection failed! stagecode = {}, subcode = {}'.format(stagecode, subcode))