diff options
author | Karel Kočí <cynerd@email.cz> | 2018-11-10 23:36:11 +0100 |
---|---|---|
committer | Karel Kočí <cynerd@email.cz> | 2018-11-12 19:34:52 +0100 |
commit | bbcb8d635f4c83a0a7f27bd6d3e554781780d27e (patch) | |
tree | c7340360e0518360b51e8848281348ecc5758583 /bigclown-leds | |
parent | cf452f0c431ba73719e0f3a356c78a43f74bf5ac (diff) | |
download | bigclown-leds-bbcb8d635f4c83a0a7f27bd6d3e554781780d27e.tar.gz bigclown-leds-bbcb8d635f4c83a0a7f27bd6d3e554781780d27e.tar.bz2 bigclown-leds-bbcb8d635f4c83a0a7f27bd6d3e554781780d27e.zip |
Add ability to mirror messages from thermostat to power-controller
Diffstat (limited to 'bigclown-leds')
-rwxr-xr-x | bigclown-leds | 28 |
1 files changed, 28 insertions, 0 deletions
diff --git a/bigclown-leds b/bigclown-leds new file mode 100755 index 0000000..2871d52 --- /dev/null +++ b/bigclown-leds @@ -0,0 +1,28 @@ +#!/usr/bin/env python3 +import paho.mqtt.client as mqtt + + +def on_connect(client, userdata, rc): + print("Connected with result code "+str(rc)) + client.subscribe("node/lcd-thermostat:0/led/#") + + +# The callback for when a PUBLISH message is received from the server. +def on_message(client, userdata, msg): + topic = msg.topic[26:] + client.publish( + 'node/power-controller:0/led-strip/-/' + topic, + payload=msg.payload) + + +def main(): + client = mqtt.Client() + client.on_connect = on_connect + client.on_message = on_message + + client.connect("127.0.0.1", 1883, 60) + client.loop_forever() + + +if __name__ == '__main__': + main() |