dashboard4/mqtt/service.py

import paho.mqtt.client as mqtt

def on_connect(client,userdata,rc):
  client.subscribe("$dashboard/#")

def on_message(client,userdata,msg):
  pass

client = mqtt.client()
client.on_connect = on_connect
client.on_message = on_message

client.connect('10.132.0.10','dasboard','EnigmA')


def send_msg(msg=None):
  if msg:
    client.reinitialise('dashboard',clean_session=True,userdata=None)
    client.publish('$dashboard/#',msg,qos=0,retain=False)