34 lines
683 B
Python
34 lines
683 B
Python
|
from pixelblaze import *
|
||
|
import paho.mqtt.client as mqtt
|
||
|
|
||
|
MQTT_HOST='192.168.1.1'
|
||
|
MQTT_PORT=1883
|
||
|
TOPIC = 'lcnc/job/progress'
|
||
|
|
||
|
PB_HOST = '192.168.0.161'
|
||
|
pb = Pixelblaze(PB_HOST)
|
||
|
|
||
|
def on_connect(client, userdata, flags, rc):
|
||
|
print('MQTT Connected')
|
||
|
|
||
|
try:
|
||
|
client.subscribe(TOPIC)
|
||
|
except: pass
|
||
|
|
||
|
# The callback for when a PUBLISH message is received from the server.
|
||
|
def on_message(client, userdata, msg):
|
||
|
p = float(msg.payload.decode('utf-8'))
|
||
|
pb.setVars({
|
||
|
'progress': p
|
||
|
})
|
||
|
|
||
|
client = mqtt.Client()
|
||
|
client.on_connect = on_connect
|
||
|
client.on_message = on_message
|
||
|
|
||
|
client.connect_async(MQTT_HOST, MQTT_PORT, 60)
|
||
|
|
||
|
client.loop_start()
|
||
|
|
||
|
while True: pass
|