0

我使用具有 HA 作为代理的 python 创建了一个 Mqtt 订阅……当我进行第一次连接时，我启动了我连接的所有 mqtt 按钮的一系列消息，即使我没有激活它们，因为我的订阅是“house/click/# ”。列表完成后……如果您按下按钮，我就会开始收到我需要的消息……有没有办法删除它给我的第一个列表。

这是我使用的代码：

import paho.mqtt.client as paho
import pandas as pd
import pyautogui
import os
import platform


def on_subscribe(client, userdata, mid, granted_qos):
    print("Subscribed: "+str(mid)+" "+str(granted_qos))


def on_message(client, userdata, msg):
    pyautogui.FAILSAFE=False
    os_system=platform.system()


    # Selezione area dello screenshot

    if os_system == 'Darwin':
        region=(10,80, 850, 100) #MAC
    else:
        region=(60,130,900,250) #RASP

    tab_pos=pd.read_csv('table_position.csv')
    print(msg.topic+"  "+str(msg.payload)+" "+str(msg.qos))
    mqtt_name=str(msg.topic).split("click/")[0]+str(msg.topic).split("click/")[1]
    mqtt_payload=msg.payload.decode('utf-8')
    index_loc=tab_pos.index[tab_pos['mqtt_topic'] == mqtt_name].tolist()
    x_loc=tab_pos.iloc[index_loc[0]][0]
    y_loc=tab_pos.iloc[index_loc[0]][1]
    new_xloc=x_loc+region[0]
    new_yloc=y_loc+region[1]
    if tab_pos.iloc[index_loc[0]][5] == "cover":
        if str(mqtt_payload) == "OPEN":
            if str(mqtt_payload) == "STOP":
                pyautogui.click(new_xloc+8,new_yloc+2)
                pyautogui.moveTo(region[0],region[1])
                print(str(new_xloc)+","+str(new_yloc))
            else:
                pyautogui.click(new_xloc+8,new_yloc+2)
                pyautogui.moveTo(region[0],region[1])
                print(str(new_xloc)+","+str(new_yloc))
        if str(mqtt_payload) == "CLOSE":
            if str(mqtt_payload) == "STOP":
                pyautogui.click(new_xloc+8,new_yloc+25)
                pyautogui.moveTo(region[0],region[1])
                print(str(new_xloc)+","+str(new_yloc))
            else:
                pyautogui.click(new_xloc+8,new_yloc+25)
                pyautogui.moveTo(region[0],region[1])
                print(str(new_xloc)+","+str(new_yloc))
    else:
        pyautogui.click(new_xloc+10,new_yloc+10)
        pyautogui.moveTo(region[0],region[1])
        print(str(new_xloc)+","+str(new_yloc))


client = paho.Client(client_id = "atena_mqtt_click")
client.on_subscribe = on_subscribe
client.on_message = on_message
client.username_pw_set("xxxx", "xxxxx")
client.connect("XXX.XXX.XXX.XXX", 1883)
client.subscribe("house/click/#", qos=1)
client.loop_forever()

这是输出

Subscribed: 1 (1,)
house/click/xxxxxx/light b’OFF’ 0
711,104
house/click/xxxxxx/alarm b’OFF’ 0
454,134
house/click/xxxxxx/light b’OFF’ 0
795,104
house/click/xxxxxxx/cover b’STOP’ 0

在这些消息全部聚集在一起之后，由于我对按钮的操作，我可以开始收到消息

有人可以告诉我如何在没有这些第一行的情况下进行干净的会话？

谢谢

4

1 回答 1

1

检查您的 MQTT 发布者标志。如果您的发布者使用“保留标志”，您需要将其设为 false。

并且要从主题中删除保留的消息，客户端必须将其替换为保留标志设置为 True 的另一条消息，或者客户端必须在该主题上发布保留标志设置为 True 的空白消息。这是删除保留消息的唯一方法。

“保留消息是保留标志设置为 true 的普通 MQTT 消息。代理存储最后保留的消息和该主题的相应 QoS。订阅与保留消息的主题匹配的主题模式的每个客户端都会收到订阅后立即保留消息。代理每个主题仅存储一条保留消息”。来源：https ://www.hivemq.com/blog/mqtt-essentials-part-8-retained-messages/

于 2020-08-16T20:45:33.723 回答