From 5f0a79353994d6d5fe264c75f7cd00fe803ce05c Mon Sep 17 00:00:00 2001 From: Linkis112 Date: Thu, 11 Sep 2025 15:21:03 +0200 Subject: [PATCH] make state possible --- mqtt.py | 14 ++++++++++++-- 1 file changed, 12 insertions(+), 2 deletions(-) diff --git a/mqtt.py b/mqtt.py index 75c00e5..55522d2 100644 --- a/mqtt.py +++ b/mqtt.py @@ -1,3 +1,5 @@ +import random + import paho.mqtt.client as mqtt import paho.mqtt.publish as publish @@ -15,8 +17,8 @@ def on_connect(client, userdata, flags, reason_code, properties): # The callback for when a PUBLISH message is received from the server. def on_message(client, userdata, msg): - print(msg.topic + " " + str(msg.payload)) - + if str(msg.payload) == "b'temperature'": + publish.single('homeassistant/sensor/temperature/state', str(random.randint(0, 30)), hostname='192.168.188.30', auth={'username': 'mqtt', 'password': 'mqtt'}) mqttc = mqtt.Client(protocol=mqtt.MQTTv5) mqttc.username_pw_set('mqtt', 'mqtt') @@ -28,6 +30,14 @@ mqttc.connect("192.168.188.30", 1883, 60) publish.single('test/topic', 'Hello, MQTT!', hostname='192.168.188.30', auth={'username': 'mqtt', 'password': 'mqtt'}) publish.single('test/topic/temp', '2', hostname='192.168.188.30', auth={'username': 'mqtt', 'password': 'mqtt'}) +''' +publish.single( + "homeassistant/sensor/temperature/state", + payload="23.5", + hostname="192.168.188.30", + auth={"username": "mqtt", "password": "mqtt"} +) +''' # Blocking call that processes network traffic, dispatches callbacks and # handles reconnecting. # Other loop*() functions are available that give a threaded interface and a