## MQTT
def on_connect(client, userdata, flags, rc):
    print(mqtt_topic)
    client.subscribe(mqtt_topic,qos=1)
    print("Connected")

def on_publish(client, userdata, mid):
    print("mid: "+str(mid))


def on_subscribe(client, userdata, mid, granted_qos):
    print("Subscribed: "+str(mid)+" "+str(granted_qos))

def init_mqtt(client,device_type,device_id,mqtt_host,mqtt_port,mqtt_topic):
    jstemp['device_type']=device_type
    jstemp['device_id']=device_id
    client.on_connect = on_connect
    client.on_publish = on_publish
    client.on_subscribe=on_subscribe
    client.connect(mqtt_host, int(mqtt_port))
    print(mqtt_host)