Pythonの異なるクラスモジュールのpaho mqttコールバック

Question

別のPythonモジュールでコールバック関数を定義しました。他のモジュールで定義されているそのコールバックをpaho.mqttクライアントコールバックにどのように添付すればよいですか？ために。私はdatabase.pyにデータベースへの接続やメッセージをデータベースとmqttbroker.pyモジュールに格納するなど、すべてのデータベース操作を行うdatabase.pyを持っています。ここでmqtt.client（）インスタンスを作成し、ブローカに接続してトピックに登録しますon_connectやon_disconnectのようなコールバックを定義します。 on_message mqttコールバックのために、私は自分のdatabase.pyモジュールにコールバック関数を作成しました。このコールバックを添付するにはどうすればいいですか？私はdatabase.pyとmqttbroker.pyモジュールをインポートするmain.py（私のクライアント）を持っています。

Answer 1

インターフェイスを定義し、そのインターフェイスをクライアントモジュールで呼び出し、データベースモジュールで定義されたコールバックをthisインターフェイスにアタッチします。

#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)