34 lines
797 B
Python
Executable file
34 lines
797 B
Python
Executable file
#!/bin/python
|
|
|
|
import time
|
|
import paho.mqtt.client as mqtt
|
|
import json
|
|
|
|
import mqtt_client
|
|
|
|
|
|
def on_connect(client, userdata, flags, reason_code, properties):
|
|
print(f"Connected: {reason_code}")
|
|
client.subscribe("#")
|
|
|
|
|
|
def on_message(client, userdata, msg):
|
|
print(f"{msg.topic}: {msg.payload.decode()}")
|
|
|
|
|
|
client = mqtt.Client(callback_api_version=mqtt.CallbackAPIVersion.VERSION2)
|
|
client.on_connect = on_connect
|
|
client.on_message = on_message
|
|
|
|
client.connect(mqtt_client.MQTT_SERVER_ADDRESS, mqtt_client.MQTT_SERVER_PORT, 60)
|
|
client.loop_start()
|
|
|
|
j = json.dumps({"command": "scene_recall", "args": {"scene_id": 0}})
|
|
# j = json.dumps({'command': 'shutdown'})
|
|
|
|
client.publish(mqtt_client.MQTT_TOPIC, payload=j, qos=0, retain=False)
|
|
|
|
time.sleep(2)
|
|
|
|
client.loop_stop()
|
|
client.disconnect()
|