Comment stocker MQTT Mosquitto publier des événements dans MySQL?

Question

J'ai connecté un périphérique qui communique avec mon serveur mosquitto MQTT (RPi) et envoie des publications vers un sujet spécifique. Ce que je veux faire maintenant est de stocker les messages publiés sur ce sujet sur le serveur MQTT dans une base de données MySQL. Je sais comment fonctionne MySQL, mais je ne sais pas comment écouter ces nouvelles publications. Je suis à la recherche d'une solution légère qui fonctionne en arrière-plan. Les pointeurs ou les idées sur les bibliothèques à utiliser sont les bienvenus.

Answer 1

Si vous êtes familier avec Python, le Paho MQTT library est simple, léger sur les ressources, et s'interface bien avec Mosquitto. Pour l'utiliser, inscrivez-vous simplement au sujet et configurez un rappel pour transmettre la charge à MySQL en utilisant peewee comme indiqué dans this answer. Exécutez le script en arrière-plan et appelez-le bien!