smims/dogmaster
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

make state possible

Browse source
This commit is contained in:
Linkis112 2025-09-11 15:21:03 +02:00
parent cc3a21b0d1
commit 5f0a793539
1 changed files with 12 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

14
mqtt.py
View file

@ -1,3 +1,5 @@
import random
import paho.mqtt.client as mqtt import paho.mqtt.client as mqtt
import paho.mqtt.publish as publish 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. # The callback for when a PUBLISH message is received from the server.
def on_message(client, userdata, msg): 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 = mqtt.Client(protocol=mqtt.MQTTv5)
mqttc.username_pw_set('mqtt', 'mqtt') 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', '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('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 # Blocking call that processes network traffic, dispatches callbacks and
# handles reconnecting. # handles reconnecting.
# Other loop*() functions are available that give a threaded interface and a # Other loop*() functions are available that give a threaded interface and a