dockerized home status service

compose.yml

@@ -3,8 +3,8 @@ services:
     #socket_domain ipv4 https://github.com/eclipse/mosquitto/issues/1004
     image: eclipse-mosquitto
     ports:
-      - "1883:1883"
-      - "1884:1884"
+      - 1883:1883
+      - 1884:1884
     volumes:
       - ${PWD}/containers/mosquitto/mosquitto.conf:/mosquitto/config/mosquitto.conf:ro
     restart: unless-stopped
@@ -17,10 +17,17 @@ services:
       - ${PWD}/containers/influxdb/data:/var/log/influx
     environment:
       - INFLUXDB_DB:=mqtt
+  home_status:
+    build: ./home_status
+    volumes:
+      - /var/log/home_status:/var/log/home_status
+    environment:
+      - BROKER=10.0.0.91
   chronograf:
     image: chronograf
     ports:
       - "8888:8888"
+
   grafana:
     image: grafana/grafana
     ports:

home_status/Dockerfile

@@ -0,0 +1,10 @@
+FROM python:3.9-slim
+
+WORKDIR /app
+
+COPY requirements.txt .
+RUN pip install -r requirements.txt
+COPY *.py .
+COPY config.json .
+
+ENTRYPOINT ["python", "home.py"]

py/home_status/config.json → home_status/config.json

@@ -1,6 +1,5 @@
 {  
     "mqtt":{
-        "host":"mqtt_broquer",
         "port":1883,
         "keepalive":60,
         "client_id":"home_status_client",
@@ -48,7 +47,7 @@
         }
     },
     "log":{
-        "logfile":"/home/pi/share/home_status(date).log",
+        "logfile":"/var/log/home_status/(date).log",
         "level":"Info"
     }
 }

py/home_status/home.py → home_status/home.py

@@ -1,12 +1,6 @@
-#https://github.com/studioimaginaire/phue
-
-
-#https://pypi.python.org/pypi/paho-mqtt/1.1
-import paho.mqtt.client as mqtt
 import json
 from time import sleep
 import logging as log
-import sys,os
 import cfg
 from mqtt import mqtt_start
 import requests

py/home_status/mqtt.py → home_status/mqtt.py

@@ -1,9 +1,7 @@
 import paho.mqtt.client as mqtt
-import datetime
 import logging as log
-import cfg
-from time import sleep,time
-import json
+from time import sleep
+import os
 import socket
 
 conf = {}
@@ -36,9 +34,10 @@ def mqtt_connect_retries(client):
         connected = False
         while(not connected):
             try:
-                client.connect(config["mqtt"]["host"], config["mqtt"]["port"], config["mqtt"]["keepalive"])
+                host = os.environ.get("BROKER","mqtt_broquer")
+                client.connect(host, config["mqtt"]["port"], config["mqtt"]["keepalive"])
                 connected = True
-                log.info(  "mqtt> connected to "+config["mqtt"]["host"]+":"+str(config["mqtt"]["port"])+" with id: "+ cid )
+                log.info(  "mqtt> connected to "+host+":"+str(config["mqtt"]["port"])+" with id: "+ cid )
             except socket.error:
                 log.error("socket.error will try a reconnection in 10 s")
                 sleep(10)

py/home_status/requirements.txt → home_status/requirements.txt

@@ -1 +1,2 @@
 paho-mqtt
+requests