logging file added

app.py

+import uvicorn as uvicorn
+
+from scripts.config.application_config import server_path, port_no
+
+if __name__ == "__main__":
+    try:
+        uvicorn.run(server_path, port=int(port_no), reload=True)
+    except Exception as e:
+        print(str(e))

conf/app.conf

+[connect_mqtt]
+
+host_nm=192.168.0.220
+port=1883
+time=60
+topic=hospital/patients
+[server]
+server_path=scripts.services.subscriber:app
+port=8449
+[logging]
+file_name=scripts\external\logging_log
\ No newline at end of file

scripts/config/application_config.py

+from configparser import ConfigParser, NoOptionError
+
+try:
+    config = ConfigParser()
+    config.read(r'E:\MQTT-redis_subscriber\conf\app.conf')
+    server_path = config.get("server", "server_path")
+    port_no = config.get("server", "port")
+    host_name = config.get("connect_mqtt", "host_nm")
+    port_num = config.get("connect_mqtt", "port")
+    topic_name = config.get("connect_mqtt", "topic")
+    time_out = config.get("connect_mqtt", "time")
+    file_name = config.get("logging", "file_name")
+except NoOptionError:
+    print("could not find conf file")

scripts/constants/end_points.py

+class EndPoints:
+    root = "/"
+    subscribe = "/subscribe"

scripts/services/main.py → scripts/core/handlers/sub_handler.py

 import paho.mqtt.client as mqtt
+from scripts.config.application_config import port_num, host_name, topic_name
 
 
-def on_connect(client, userdata, flags, rc):
+class subscriber:
+    @staticmethod
+    def subscribe():
+        def on_connect(client, userdata, flags, rc):
             print("Connected with result code " + str(rc))
-    client.subscribe("hospital/patients")
+            client.subscribe(topic_name)
 
-
-def on_message(client, userdata, msg):
+        def on_message(client, userdata, msg):
             print("Topic: " + msg.topic + "\nMessage: " + str(msg.payload))
 
-
-client = mqtt.Client()
-client.on_connect = on_connect
-client.on_message = on_message
-
-client.connect("192.168.0.220", 1883, 60)
-
-client.loop_forever()
+        client = mqtt.Client()
+        client.on_connect = on_connect
+        client.on_message = on_message
+        client.connect(host_name, int(port_num), 60)
+        client.loop_forever()

scripts/logging/logging.py

+import logging
+import os
+from logging.handlers import RotatingFileHandler
+from scripts.config.application_config import file_name
+
+
+def get_logger():
+    """
+     Creates a rotating log
+     """
+    __logger__ = logging.getLogger('')
+    __logger__.setLevel("ERROR")
+    log_formatter = '%(asctime)s - %(levelname)-6s - [%(threadName)5s:%(funcName)5s():%(lineno)s] - %(message)s'
+    time_format = "%Y-%m-%d %H:%M:%S"
+    formatter = logging.Formatter(log_formatter, time_format)
+    log_file = os.path.join(f"{file_name}_ERROR.log")
+    temp_handler = RotatingFileHandler(log_file,
+                                       maxBytes=100000000,
+                                       backupCount=5)
+    temp_handler.setFormatter(formatter)
+
+    __logger__.addHandler(temp_handler)
+
+    return __logger__
+
+
+logger = get_logger()

scripts/services/subscriber.py

+from scripts.constants.end_points import EndPoints
+from fastapi import FastAPI
+from scripts.core.handlers.sub_handler import subscriber
+from scripts.logging.logging import logger
+
+app = FastAPI()
+
+
+@app.get(EndPoints.root)
+def root():
+    return {"data": "mqtt subscriber"}
+
+
+@app.post(EndPoints.subscribe, tags=['subscribe the topic'])
+def subscribe():
+    try:
+        subscriber.subscribe()
+        return {"data", "ready for subscribe the topic"}
+    except Exception as e:
+        logger.error("cant subscribe the topic")
+        print(e)