Paho mqtt Rückrufe auf mehrere Abonnement

Question

Ich habe mehrere (rund 4) Themen mit paho.mqtt abonniert.

Bei Erhalt der Nachricht von jedem Thema, möchte ich die Nachricht zwischenspeichern, bis sie einen Schwellenwert erreicht und später Massennachrichten in MySQL-Datenbank einfügen. Ich möchte einige 1000 Nachrichten sammeln und überprüfen, ob der Schwellenwert größer als 1000 und dann ist schließlich in bestimmten Zeitintervallen in die Datenbank einfügen (für jede 1 Minute).

Für jedes Thema gibt es entsprechende Tabelle in der Datenbank. Welche Callback-Funktion sollte ich use on_message() Rückruf oder message_callback_add()? Was ist besser in einem solchen Szenario?

Answer 1

Was bedeutet "ist besser" für Sie?

Der Rückruf registriert mit on_message() wird alle Nachrichten für alle Ihre Abonnements erhalten, während mit message_callback_add Sie verschiedene Rückrufe für jedes Thema, das Sie abonnieren können.

Benötigen Sie Ihre Rückrufe, um verschiedene Dinge auf der Grundlage des Themennamens zu tun? Wenn nicht, verwenden Sie on_message, sonst verwenden Sie message_callback_add.