IOT MQTT

Documentation

npm install

Remplacer le lien de la database mongodb des fichiers consumer.js et requeue par l'url de votre base de données MongoDB.

Vérifier que vous êtes bien connecté en ouvrant mongo Atlas et en y ajoutant votre adresse IP.
Ouvrir 3 terminaux et lancer les commandes suivantes :

node producer.js

node consumer.js

node requeue.js

Ouvrir mongodb compass et vérifier que les données sont bien insérées dans la base de données.

Les messages seront mis en status 'pending' le temps que le consumer les traite. Une fois traités, ils seront mis en status 'done'.

producer.js : Envoie des messages sur le topic 'iot'.
consumer.js : Consomme les messages du topic 'iot' et les insère dans la base de données.
requeue.js : Remet les messages en status 'pending' pour les traiter à nouveau.