複数のサブスクリプションでPaho mqttコールバック

Question

私はpaho.mqttを使用して複数（約4つ）のトピックを購読しています。

各トピックからメッセージを受信すると、しきい値に達するまでメッセージをバッファし、その後、一括メッセージをMySQLデータベースに挿入したいと考えています.1000件のメッセージを収集し、しきい値が1000を超え、最後に、特定の時間間隔（1分ごと）でデータベースに挿入します。

トピックごとに、対応するテーブルがデータベースにあります。どのコールバック関数をコールバックまたはmessage_callback_add()にする必要がありますか？このようなシナリオではどちらが良いでしょうか？

Answer 1

「より良い」とはどういう意味ですか？

on_message()で登録されたコールバックは、すべての購読のメッセージを取得しますが、message_callback_addでは、購読しているトピックごとに異なるコールバックを設定できます。

トピック名に基づいてさまざまなことを行うにはコールバックが必要ですか？そうでない場合はon_messageを使用し、そうでない場合はmessage_callback_addを使用します。