updated

.idea/sonarlint/issuestore/index.pb

+
+^
+..idea/inspectionProfiles/profiles_settings.xml,1\e\1e9075f5bf079c01ef2c910709e91a497d262080
+\
+,.idea/inspectionProfiles/Project_Default.xml,4\9\496a238a6afa168dbaf6efd37bb459331589579c
\ No newline at end of file

app.py

 import uvicorn
 
-from scripts.logging.logging import logger
+from scripts.logging.logging_log import logger
 
 if __name__ == "__main__":
     try:

conf/app.conf

+[mqtt_connect]
+host=192.168.0.220
+port=1883
+file_path=scripts/external/logging_error.log
\ No newline at end of file

main.py

 import uvicorn
 from fastapi import FastAPI
-
-from scripts.logging.logging import logger
+from scripts.logging.logging_log import logger
 from scripts.services.publisher import publish
 
 app = FastAPI()

scripts/config/application_config.py

-from dotenv import load_dotenv
+from configparser import ConfigParser
 
-import os
 
 try:
-    load_dotenv()
-    host = os.getenv("MQTT_HOST")
-    port_no = os.getenv("PORT")
-    file_name = os.getenv("FILE_PATH")
+    config = ConfigParser()
+    config.read("conf/app.conf")
+    host_name = config.get("mqtt_connect", "host")
+    port_no = config.get("mqtt_connect", "port")
+    file_name = config.get("mqtt_connect", "file_path")
 except Exception as e:
     print(e)
+
+# from dotenv import load_dotenv
+# import os
+#
+# try:
+#     load_dotenv()
+#     host = os.getenv("MQTT_HOST")
+#     port_no = os.getenv("PORT")
+#     file_name = os.getenv("FILE_PATH")
+# except Exception as e:
+#     print(e)

scripts/core/handlers/publish_data.py

 import json
 import time
-
 import paho.mqtt.client as mqtt
-from scripts.config.application_config import host, port_no
+from scripts.config.application_config import host_name, port_no
 from scripts.database.model.model import SitesEncoder
-from scripts.logging.logging import logger
+from scripts.logging.logging_log import logger
 
 
 class MqttHandler:
@@ -12,12 +11,10 @@ class MqttHandler:
     def data_publish(data):
         try:
             client = mqtt.Client()
-            client.connect(host, int(port_no), 60)
+            client.connect(host_name, int(port_no), 60)
             topic = "site"
             time.sleep(10)
             client.publish(topic, json.dumps(data, cls=SitesEncoder))
         except Exception as e:
             logger.error(e)
             print(e)
-
-

scripts/database/model/model.py

 import json
-
 from pydantic import BaseModel
 
 

scripts/services/publisher.py

@@ -2,7 +2,7 @@ from fastapi import APIRouter
 from scripts.constants.endpoints import EndPoints
 from scripts.core.handlers.publish_data import MqttHandler
 from scripts.database.model.model import DataModel
-from scripts.logging.logging import logger
+from scripts.logging.logging_log import logger
 
 publish = APIRouter()