python mqtt持续上报数据

要在Python中使用MQTT持续上报数据，你可以使用paho-mqtt库。下面是一个简单的示例代码，可以帮助你开始：

import paho.mqtt.client as mqtt
import time

# MQTT连接回调
def on_connect(client, userdata, flags, rc):
    print("Connected with result code "+str(rc))
    # 订阅主题
    client.subscribe("topic")

# MQTT接收消息回调
def on_message(client, userdata, msg):
    print(msg.topic+" "+str(msg.payload))

# 创建MQTT客户端
client = mqtt.Client()

# 设置连接回调函数
client.on_connect = on_connect

# 设置消息接收回调函数
client.on_message = on_message

# 设置MQTT服务器地址和端口
client.connect("mqtt.server.com", 1883, 60)

# 循环处理网络流量和消息处理
client.loop_start()

# 持续上报数据
while True:
    # 模拟获取数据
    data = "Data to be reported"
    
    # 发布数据到指定主题
    client.publish("topic", data)
    
    # 延时一段时间
    time.sleep(1)

# 停止MQTT客户端循环
client.loop_stop()

在这个示例中，我们使用paho-mqtt库来创建一个MQTT客户端，设置连接回调和消息接收回调函数。然后，我们连接到MQTT服务器，并循环处理网络流量和消息处理。在循环中，我们模拟获取数据并使用`client.publish()`方法发布数据到指定主题。最后，我们使用`time.sleep()`方法添加延时，以便在每次上报数据之间有一定的间隔。

你需要将示例代码中的`mqtt.server.com`替换为你实际使用的MQTT服务器的地址。另外，你还需要替换`topic`为你要发布数据的主题。

这只是一个简单的示例，你可以根据自己的需求进行修改和扩展。希望对你有帮助！