Hiome MQTT example

mqtt.py

import paho.mqtt.client as mqtt
import json

def onConnect(client, userdata, flags, rc):
  client.subscribe('hs/1/com.hiome/#/occupancy', qos=1)

def onMessage(client, userdata, payload):
  topic = payload.topic.split('/')
  room_id = topic[3]
  msg = json.loads(payload.payload)
  occupancy_count = msg['val']
  # do something when occupancy changes in this room
  return

client = mqtt.Client()
client.on_connect = onConnect
client.on_message = onMessage
client.connect('hiome.local', 1883, 60)
client.loop_forever()