Management command for the mqtt loop

2 files changed, 10 insertions, 0 deletions

diff --git a/rrd/management/commands/__init__.py b/rrd/management/commands/__init__.py
new file mode 100644
index 0000000..e69de29
--- /dev/null
+++ b/rrd/management/commands/__init__.py
diff --git a/rrd/management/commands/listen_mqtt.py b/rrd/management/commands/listen_mqtt.py
new file mode 100644
index 0000000..758a4f2
--- /dev/null
+++ b/rrd/management/commands/listen_mqtt.py
@@ -0,0 +1,10 @@
+from django.core.management.base import BaseCommand
+
+import rrd.mqtt
+
+class Command(BaseCommand):
+    help = "Listen to mqtt events and update rrd files and graphs"
+
+    def handle(self, *args, **kw):
+        mqtt_client = rrd.mqtt.MQTTClient()
+        mqtt_client.loop_forever()