MQTT(Message Queuing Telemetry Transport)是一种轻量级的即时通信协议。
Paho 是Eclipse的开源 MQTT 客户端项目，提供多种语言的 MQTT 客户端实现，包括 C、C++、C#、Java、Python、JavaScript 等。
在Python环境下，Paho MQTT Python客户端由paho-mqtt模块支撑，使用前需要先安装。
用pip安装paho-mqtt：
pip install paho-mqtt
使用paho-mqtt上报数据到Mqtt服务器的示例：
import paho.mqtt.client as mqtt
HOST = "mqtt.agile-iot.com" #替换为实际的服务器地址
PORT = 1883
def on_message_callback(client, userdata, message):
print(message.topic + " " + ":" + str(message.payload))
def on_connect(client, userdata, flags, rc):
print("Connected with result code " + str(rc))
client.subscribe("agile_01")
def main():
#替换为实际的client id，具体要求需要查对应的服务器手册
client = mqtt.Client('xxxx')
client.connect(HOST, PORT, 60)
#连接用户名和密码
client.username_pw_set('agile-user', 'agile-pwd')
client.on_connect = on_connect
#上报payload，按实际修改，一般用JSON格式
pl = '{"factoryId":"fc01","edgeId":"edge01","startTimeStamp":1652500178755,"seq":1,"dataTimeStamp":1652500205000,"dataType":"data","data":[{"devId":"dev1","tag":"tag_01","ts":"1652500205000","vt":"int","v":1234,"vq":0,"seq":1}]}'
#推送到指定的topic
client.publish("agile/real/topic", pl, 1)
client.on_message = on_message_callback
client.loop_forever()
main()
上报协议设计，参考：设备联网数据上传协议设计_PascalMing的博客-CSDN博客_上传数据协议
Paho MQTT库详细介绍，参考：
Paho MQTT Python客户端常用API、安装与使用_Forskamse的博客-CSDN博客_paho-mqtt python
