debug the project

app.py

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

conf/application.conf

 [server]
-server_path=scripts.services.fastapi_services:app
-port=8000
-[mongo]
+server_path=scripts.services.main:app
+port=8884
+[mongo_path]
 uri=mongodb://localhost:27017
-port=27017
\ No newline at end of file
+port=27017
+[logging]
+file_path=scripts/externals/logging_log

scripts/config/application_config.py

@@ -3,13 +3,13 @@ import configparser
 try:
     config = configparser.ConfigParser()
     config.read('conf/application.conf')
-    # # path of csv file
-    # file_path = config.get("path", "base_path")
-    # # mongo connect
-    mongo_uri = config.get("mongo", "uri")
-    port_connect = config.get("mongo", "port")
+    # mongo connect
+    mongo_uri = config.get("mongo_path", "uri")
+    port_connect = config.get("mongo_path", "port")
     # # server
-    server_path = config.get("server", "server_path")
+    path = config.get("server", "server_path")
     port_no = config.get("server", "port")
+    # logging file path
+    file_path = config.get("logging", "file_path")
 except configparser.NoOptionError:
     print("could not read configuration file")

scripts/constants/end_points.py

 class EndPoints:
-    upload="/upload"
-    send_data="/send_data"
-    update="/update_data/{doc_id}"
-    delete="/delete_data/{doc_id}"
-
+    upload = "/upload"
+    send_data = "/send_data"
+    update = "/update_data/{doc_id}"
+    delete = "/delete_data/{doc_id}"

scripts/core/handlers/fastapi_handler.py

+from scripts.constants.db_connect import collection
 from scripts.database.model import employee_insert
-from scripts.services.fastapi_services import collection
 
 
 class fastAPIHandler:

scripts/logging/logger_conf.yml

+logger:
+  name: fastapi
+  level: DEBUG
+  handlers:
+    - type: RotatingFileHandler
+      max_bytes: 100000000
+      back_up_count: 5
+
+    - type: SocketHandler
+      host: localhost
+      port: 8000
+
+    - type: StreamHandler
+      name: fastapi crud

scripts/logging/logging.py

@@ -5,7 +5,7 @@ from logging.handlers import RotatingFileHandler, SocketHandler
 
 import yaml
 
-# from scripts.constants.app_configuration import PathToStorage
+from scripts.config.application_config import file_path
 
 
 # this method is to read the configuration from backup.conf
@@ -32,10 +32,8 @@ def get_logger():
      """
     __logger__ = logging.getLogger('')
     __logger__.setLevel(logging_config["level"].upper())
-    log_formatter = '%(asctime)s - %(levelname)-6s - [%(threadName)5s:%(funcName)5s():''' \
-                    '%(lineno)s] - %(message)s'
+    log_formatter = '%(asctime)s - %(levelname)-6s - [%(threadName)5s:%(funcName)5s():%(lineno)s] - %(message)s'
     time_format = "%Y-%m-%d %H:%M:%S"
-    file_path = PathToStorage.LOGS_MODULE_PATH
     formatter = logging.Formatter(log_formatter, time_format)
 
     for each_handler in logging_config["handlers"]:
@@ -47,14 +45,6 @@ def get_logger():
                                                maxBytes=each_handler["max_bytes"],
                                                backupCount=each_handler["back_up_count"])
             temp_handler.setFormatter(formatter)
-        elif each_handler["type"] in ["SocketHandler"]:
-            temp_handler = SocketHandler(each_handler["host"], each_handler["port"])
-        elif each_handler["type"] in ["StreamHandler"]:
-            temp_handler = StreamHandler()
-            temp_handler.setFormatter(formatter)
-
-        else:
-            temp_handler = None
         __logger__.addHandler(temp_handler)
 
     return __logger__

scripts/services/fastapi_services.py

-import logging
-
-from fastapi import FastAPI, UploadFile
-from mongoengine import connect
-from scripts.config.application_config import port_connect
-from scripts.constants.db_connect import db_connect, collection
-from scripts.constants.end_points import EndPoints
-from scripts.core.handlers.fastapi_handler import fastAPIHandler
-from scripts.database.model import employee_insert, employee_update
-import pandas as pd
-
-app = FastAPI()
-connect(db="employees", host="localhost", port=int(port_connect))
-
-
-@app.get("/")
-async def root():
-    return {"data": "FastAPI CRUD Operations"}
-
-
-# upload and insert into database
-@app.post(EndPoints.upload, tags=["upload file"])
-async def upload_file(file: UploadFile):
-    try:
-        file_content = pd.read_csv(file.file)
-        fastAPIHandler.file_upload(file_content)
-
-        return {"data": "CSV data uploaded successfully"}
-    except Exception as e:
-        logging.error(f'upload file failed:{e}')
-        print(e)
-
-
-# insert data using post method
-@app.post(EndPoints.send_data, tags=['send data'])
-def send_data(emp: employee_insert):
-    try:
-        fastAPIHandler.insert_data(emp)
-        return {"message": "new data has been inserted"}
-    except Exception as e:
-        logging.error(f'inserting a document failed {e}')
-
-
-# update data
-@app.put(EndPoints.update, tags=["update database"])
-def update_data(doc_id: int, details: employee_update):
-    try:
-        fastAPIHandler.update_data(doc_id, details)
-        return {"data": "data updated"}
-    except Exception as e:
-        logging.error(f'updating the data failed {e}')
-
-
-# delete data
-@app.delete(EndPoints.delete, tags=["delete data"])
-def delete_data(doc_id: int):
-    try:
-        fastAPIHandler.delete_data(doc_id)
-        return {"data": "data deleted"}
-    except Exception as e:
-        logging.error(f'deleting a document failed {e}')

scripts/utils/mongo_utils.py

@@ -5,5 +5,3 @@ def create_collection(db):
         return collection
     except Exception as e:
         print(str(e))
-
-