python
def __init__(self, mqttaddr, AccessToken, ProjectKey, serverport)

python
def connect(self)

python
def reconnect(self)

python
def update(self, json_data)

python
def on_subcribe(self, topic, msg)

python
def task_mqtt(self)

python
def send_info(self, dic_info, delay_Time)

python
def reg_callback(self, reg_addr, value)

python
def init_mqtt()

json
{
    "mqttaddr": "mqtt服务器地址",
    "AccessToken": "访问令牌",
    "ProjectKey": "项目密钥",
    "serverport": 端口号
}

python
send_data = {
    "Flow01": 4.503,          # 流量1
    "Flow02": 1.501,          # 流量2
    ...
    "Flow12": 2.501,          # 流量12
    "Temperature": 120.01,     # 温度
    "Status": "start heating", # 状态
    "TimeRemaining": "500:00:00" # 剩余时间
}

python
from mqtt import init_mqtt

# 初始化MQTT
mqtt_client = init_mqtt()

# 准备数据
data = {
    "Temperature": 25.5,
    "Status": "Running"
}

# 发送数据
if mqtt_client:
    mqtt_client.update(data)

python
def on_message(data):
    print(f"Received: {data}")

mqtt_client = init_mqtt()
mqtt_client.reg_callback('_recv_callback', on_message)