1. siot库

SIoT是一款开源的MQTT服务器,siot则是Python和MicroPython的一个库。

1.1. 简介

MQTT的库明显不好用,前面要定义一个类,代码还很长,让初学者紧张。

siot是虚谷物联团队写的一个Python库。为了让初学者能够写出更加简洁、优雅的Python代码。

siot库同时支持MicroPython,语法完全一致。

1.2. 安装

使用pip命令

1.3. 官方地址

  • GitHub地址:

1.4. 使用说明

1.导入库

from siot import iot

2.连接MQTT服务器

siot = iot(CLIENT_ID, SERVER, user=IOT_UserName, password=IOT_PassWord)

siot.connect()

siot.loop()

3.发送消息

siot.publish(IOT_pubTopic, “value %d”%tick)

4.订阅消息

siot.subscribe(IOT_pubTopic, sub_cb)

“sub_cb”为回调函数的名称,需要写一个名称为“sub_cb”的函数,带3个参数,其中msg为订阅的消息,为一个元组,属性有topic和payload。如下面的代码。

::
def sub_cb(client, userdata, msg):
print(“nTopic:” + str(msg.topic) + ” Message:” + str(msg.payload))

1.5. 代码范例

1.发送消息:

from siot import iot
import time

SERVER = "127.0.0.1"            #MQTT服务器IP
CLIENT_ID = ""                  #在SIoT上,CLIENT_ID可以留空
IOT_pubTopic  = 'xzr/001'       #“topic”为“项目名称/设备名称”
IOT_UserName ='siot'            #用户名
IOT_PassWord ='dfrobot'         #密码

siot = iot(CLIENT_ID, SERVER, user=IOT_UserName, password=IOT_PassWord)
siot.connect()
siot.loop()

tick = 0

try:
    while True:
        siot.publish(IOT_pubTopic, "value %d"%tick)
        time.sleep(1)           #隔1秒发送一次
        tick = tick+1
except:
    siot.stop()
    print("disconnect seccused")
  • 订阅消息:
from siot import iot
import time

SERVER = "127.0.0.1"        #MQTT服务器IP
CLIENT_ID = ""              #在SIoT上,CLIENT_ID可以留空
IOT_pubTopic  = 'xzr/001'   #“topic”为“项目名称/设备名称”
IOT_UserName ='siot'        #用户名
IOT_PassWord ='dfrobot'     #密码

def sub_cb(client, userdata, msg):
  print("\nTopic:" + str(msg.topic) + " Message:" + str(msg.payload))

siot = iot(CLIENT_ID, SERVER, user=IOT_UserName, password=IOT_PassWord)
siot.connect()
siot.subscribe(IOT_pubTopic, sub_cb)
siot.loop()

try:
  while True:
    pass
except:
  siot.stop()
  print("disconnect seccused")