MQTT sensor side example

This is for sensor side code powered by Raspberry Pi.
Main purpose of this program in to update (publish) sensor data to correct mqtt topics, "sensors/sht11temp" and "sensors/sht11hum".

# MQTT sensor side example code

import sys
!{sys.executable} -m pip install paho-mqtt

#!/usr/bin/python
import time
import socket
import paho.mqtt.client as mqtt
import paho.mqtt.publish as publish
import time
import random
from time import gmtime, strftime
from datetime import datetime
import sys
import json
import socket
import string

serveraddr = "0.0.0.0"
serverport = 1883
interval = 60

# when connecting to mqtt do this;
def on_connect(client, userdata, flags, rc):
    if rc == 0:
         client.connected_flag = True #set flag
         print("connected OK")
    else:
         print("Bad connection Returned code=",rc)

# INFO
# message will be json
# format '{"<key>","<value"}'



def on_publish(mosq, obj, mid):
    print("mid: " + str(mid))

mqtt.Client.connected_flag = False
client = mqtt.Client("sensorRasp") #Client name
client.on_connect = on_connect #Bind call back function
client.on_message = on_message #Bind call back function
#client.connect("0.0.0.0", 1883, 60)
client.loop_start()
client.connect(serveraddr, serverport, interval) #Connect to broker
while not client.connected_flag:
    print("In wait loop")
    time.sleep(1)
client.subscribe(("actuators/#",1))

while True:

    sht11_temp = random.randrange(10)
    sht11_hum = random.randrange(10)

    # msg objects("< topicname >", "< payload >", qos, retain)
    publish.multiple({
    ("sensors/sht11_temp", str(sht11_temp),0,True),
    ("sensors/sht11_hum", str(sht11_hum),0,True),
    })

    time.sleep(10)