owntracks-publishing-subscribing

import paho.mqtt.client as mqtt                                         #necessary imports
import json, os
from datetime import date, datetime
import time
# sqlite3

def on_log(client, userdata, level, buf):
    print(buf)

def on_connect(client, userdata, flags, rc):
    if rc==0:
        client.connected_flag = True                                    #set flag
        print("connected OK Returned code=",rc)                         #let us know we connected to the broker
        client.subscribe("owntracks/KS/#")                        #we are connected, so subscribe to the topic. wildcard means any device
        print("rc")
    else:
        print("Bad connection Returned code=",rc)                #if we can't connect
        client.loop_stop()

def on_disconnect(client, userdata, rc):
    print("client disconnected ok")     
   
     

""" callback function for messages published """
def on_publish(client, userdata, mid):
    print ("in on_pub callback mid= ", mid)
      #  client.loop_stop()

      
def on_subscribe(client, userdata, mid, granted_qos):
    print("subscribed")

""" callback function for messages received """
def on_message( client, userdata, msg, mid ):                                #client method to get messages from topic
    topic = msg.topic                                                   #for use when we can't decode
    try:
      data = json.loads(msg.payload.decode("utf8"))                   #decode message
      day = date.today()                                              #time functions
      clock = datetime.now()
      time = datetime.time(clock)
      print ("TID = {0} is currently at {1}, {2},{3},{4}".format(data['tid'], data['lat'], data['lon'], str(day), str(time)), mid)
                                                                        #print device, latitude and longitude from the message; add time data
      print(str(data))                                                #print the entire message just for fun
    except:
        print ("Cannot decode data on topic {0}".format(topic))         #cannot decode; print the topic for the non-decodable message

def reset ():
    ret=client.publish("house/temperature1", "",  0, True)

#ret=client.publish("house/temperature1", "Test Message 0", 0)

mqtt.Client.connected_flag=False #create flag in class

client = mqtt.Client() 
client.on_log=on_log
client.on_connect = on_connect
client.on_disconnect=on_disconnect

client.on_publish = on_publish
client.connect("broker.hivemq.com", 1883)                             #connect to the broker on an appropriate port
client.loop_start()

while not client.connected_flag:  #wait in loop
    print("in wait loop")
    time.sleep(1)
time.sleep(3)   
print("publishing")
ret=client.publish("house/temperature1", "Test Message 0", 0)
print("publish return=", ret)
time.sleep(3)
ret=client.publish("house/temperature1", "Test Message 1", 1)
print("publish return=", ret)
time.sleep(3)
ret=client.publish("house/temperature1", "Test Message 2", 2)
time.sleep(3)
client.subscribe("house/temperature1", 2)
time.sleep(10)
client.loop_stop()
client.disconnect()