use MQTT credentials from mqtt_client.py
This commit is contained in:
parent
0f3ab79bdb
commit
238aada4a1
1 changed files with 4 additions and 6 deletions
|
@ -4,9 +4,7 @@ import time
|
||||||
import paho.mqtt.client as mqtt
|
import paho.mqtt.client as mqtt
|
||||||
import json
|
import json
|
||||||
|
|
||||||
MQTT_SERVER_ADDRESS = "localhost"
|
import mqtt_client
|
||||||
MQTT_SERVER_PORT = 1883
|
|
||||||
MQTT_TOPIC = "homeassistant/device/mixer"
|
|
||||||
|
|
||||||
|
|
||||||
def on_connect(client, userdata, flags, reason_code, properties):
|
def on_connect(client, userdata, flags, reason_code, properties):
|
||||||
|
@ -22,13 +20,13 @@ client = mqtt.Client(callback_api_version=mqtt.CallbackAPIVersion.VERSION2)
|
||||||
client.on_connect = on_connect
|
client.on_connect = on_connect
|
||||||
client.on_message = on_message
|
client.on_message = on_message
|
||||||
|
|
||||||
client.connect(MQTT_SERVER_ADDRESS, MQTT_SERVER_PORT, 60)
|
client.connect(mqtt_client.MQTT_SERVER_ADDRESS, mqtt_client.MQTT_SERVER_PORT, 60)
|
||||||
client.loop_start()
|
client.loop_start()
|
||||||
|
|
||||||
j = json.dumps({"command": "scene_recall", "args": {"scene_id": 42}})
|
j = json.dumps({"command": "scene_recall", "args": {"scene_id": 0}})
|
||||||
# j = json.dumps({'command': 'shutdown'})
|
# j = json.dumps({'command': 'shutdown'})
|
||||||
|
|
||||||
client.publish(MQTT_TOPIC, payload=j, qos=0, retain=False)
|
client.publish(mqtt_client.MQTT_TOPIC, payload=j, qos=0, retain=False)
|
||||||
|
|
||||||
time.sleep(2)
|
time.sleep(2)
|
||||||
|
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue