26 lines
607 B
Python
26 lines
607 B
Python
|
import paho.mqtt.subscribe as mqtt
|
||
|
|
import json
|
||
|
|
|
||
|
|
BROKER = ('homeproxy', 1883)
|
||
|
|
TOPIC_RAW = 'scalefix/raw/weight'
|
||
|
|
TOPIC_USERS = 'scalefix/users'
|
||
|
|
|
||
|
|
|
||
|
|
_users={}
|
||
|
|
|
||
|
|
def handle_weight(client, userdata, message):
|
||
|
|
pass
|
||
|
|
|
||
|
|
def handle_user(client, userdata, message):
|
||
|
|
pass
|
||
|
|
|
||
|
|
|
||
|
|
TOPIC_LAST = TOPIC_USERS+'/last'
|
||
|
|
def dispatch(client, userdata, message):
|
||
|
|
if message.topic == TOPIC_RAW:
|
||
|
|
handle_weight(client, userdata, message)
|
||
|
|
elif message.topic.startswith(TOPIC_LAST):
|
||
|
|
handle_user(client, userdata, message)
|
||
|
|
|
||
|
|
mq.callback(dispatch, [TOPIC_RAW, TOPIC_LAST+'/+'], hostname=BROKER[0], port=BROKER[1])
|