python paho mqtt thread

Luca Sanna sanluca78 at gmail.com
Thu May 21 16:05:39 EDT 2015


hi ,
I try to run this code MQTT but I can not read the messages in the topic , can you help me ?
thanks

class MyMQTTClass(Thread):
    #def __init__(self, clientid=None):
    clientid=None
    _mqttc = mqtt.Client(clientid)
    #_mqttc.on_message = mqtt_on_message
    #_mqttc.on_connect = mqtt_on_connect
    #_mqttc.on_publish = mqtt_on_publish
    #_mqttc.on_subscribe = mqtt_on_subscribe
    db=Mydata()
        
    def mqtt_on_connect(self, mqttc, obj, flags, rc):
        #print("rc: "+str(rc))
        pass
        
    def mqtt_on_message(self, mqttc, obj, msg):
        #print(msg.topic+" "+str(msg.qos)+" "+str(msg.payload))
        if msg.topic=="home/soggiorno/luce":
            if msg.paylod=="ON":
                self.db.update_configure('power',1,1)
            else:
                self.db.update_configure('power',0,1)
                
    def mqtt_on_publish(self, mqttc, obj, mid):
        #print("mid: "+str(mid))
        pass
        
    def mqtt_on_subscribe(self, mqttc, obj, mid, granted_qos):
        #print("Subscribed: "+str(mid)+" "+str(granted_qos))
        pass
        
    def mqtt_on_log(self, mqttc, obj, level, string):
        #print(string)
        pass
        
    def run(self):
        logCritical("run")
        self._mqttc.on_message = self.mqtt_on_message
        rc=0
        while rc==0:
        
            self._mqttc.connect("192.168.1.60", 1883, 60)
            self._mqttc.subscribe("home/soggiorno/temperatura")
            self._mqttc.subscribe("home/soggiorno/umidita")
            self._mqttc.subscribe("home/soggiorno/luce")
            self.mqtt_on_message
            rc=self._mqttc.loop()



More information about the Python-list mailing list