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()
--
https://mail.python.org/mailman/listinfo/python-list
