paho mqtt Callbacks in verschiedenen Klassenmodulen in Python

Question

Ich habe meine Callback-Funktion in einem anderen Python-Modul definiert. Wie füge ich diesen Callback, der in einem anderen Modul definiert ist, an paho.mqtt Client Callback an? Zum. ZB habe ich eine Datenbank.py, wo ich alle Datenbankoperationen wie Verbindung zur Datenbank und Speichern der Nachrichten in der Datenbank und mqttbroker.py Modul, wo ich eine mqtt.client() - Instanz erstellen und eine Verbindung zum Broker und abonnieren Sie die Themen und einige Callbacks wie on_connect und on_disconnect definieren. Jetzt für Callback on_message mqtt, habe ich die Callback-Funktion in meinem Modul Datenbank.py erstellt. Wie füge ich diesen Rückruf an? Ich habe main.py (mein Client), der das Modul database.py und mqttbroker.py importiert.

Answer 1

Definieren Sie die Schnittstelle und rufen Sie diese Schnittstelle im Clientmodul auf und hängen Sie den im Datenbankmodul definierten Rückruf an diese aufgerufene Schnittstelle an.

#mqttbroker.py 
def onMessage(self, callback): 
     self.client.on_message = callback 
     self.client.loop_forever() 

#database.py 
def on_message(self,client,userdata, msg) 
    #store messsages in db 

#main.py 
import mqqtbroker 
import database 

client = mqqtbroker() 
client.connect(host, port, 60) 
client.onMessage(database.on_message)