Python MQTT 协议 定时上传不同的数据

MQTTX 是一款MQTT 协议的消息发送和接收工具，它可以用于定时上传不同的数据。以下是一个简单的 Python 脚本，使用 paho-mqtt 库来实现定时上传不同数据到MQTT服务器。

import paho.mqtt.client as mqtt
import random
import time

# MQTT 配置
broker_address = "mqtt服务器地址"
port = 1883  # 默认端口
topic = "your/topic"  # 你的主题

# 连接到MQTT服务器
client = mqtt.Client("PythonClient")
client.connect(broker_address, port=port)

# 定时任务函数
def timed_task():
    # 这里可以根据需要上传不同的数据
    data = {"sensor": "sensor_id", "value": random.randint(0, 100)}
    message = json.dumps(data)  # 将字典转换为JSON字符串
    client.publish(topic, message)  # 发布消息

# 主程序
if __name__ == '__main__':
    interval = 5  # 定时任务的间隔时间（秒）
    while True:
        timed_task()
        time.sleep(interval)

确保你的 MQTT 服务器地址、端口、主题和认证信息（如果有的话）是正确的。这个脚本会在每个指定的时间间隔内随机生成一个0到100之间的数值，并将其作为JSON格式的消息上传到MQTT服务器。

注意：确保你的MQTT服务器运行在你的本地机器或者你有权限访问。如果你使用的是第三方的MQTT服务，你需要提供正确的服务器地址、端口和认证信息。

v2

import paho.mqtt.client as mqtt
import random
import json
import time

# MQTT 配置
broker_address = "192.168.19.165"   # mqtt服务器地址
port = 1883  # 默认端口
topic = "tab/1"  # 你的主题

# 连接到MQTT服务器
client = mqtt.Client("cnzt")
client.connect(broker_address, port=port)

# 定时任务函数
def timed_task():
    # 这里可以根据需要上传不同的数据
    data = {"a1": "3.14", "b1": "1234"}
    message = json.dumps(data)  # 将字典转换为JSON字符串
    client.publish(topic, message)  # 发布消息

# 主程序
if __name__ == '__main__':
    interval = 2  # 定时任务的间隔时间（秒）
    while True:
        timed_task()
        time.sleep(interval)