Commit 3c76b831 by ajil.k

updated

parent 367a5719
# importing libraries # importing libraries
import uvicorn import uvicorn
from scripts.constants.app_configuration import port_no
if __name__ == "__main__": if __name__ == "__main__":
try: try:
uvicorn.run("scripts.services.main:app", port=8000, reload=True) uvicorn.run("scripts.services.main:app", port=int(port_no), reload=True)
except Exception as e: except Exception as e:
print("Error-", e) print("Error-", e)
[MongoDB] [MongoDB]
mongo_uri = mongodb://localhost:27017/ mongo_uri = mongodb://localhost:27017/
port = 8000
[DataPath] [DataPath]
csv_path = temp/data.csv csv_path = temp/data.csv
\ No newline at end of file
...@@ -5,5 +5,6 @@ config = ConfigParser() ...@@ -5,5 +5,6 @@ config = ConfigParser()
config.read(f"conf/application.conf") config.read(f"conf/application.conf")
uri = config.get("MongoDB", "mongo_uri") uri = config.get("MongoDB", "mongo_uri")
port_no = config.get("MongoDB", "port")
csv_path = config.get("DataPath", "csv_path") csv_path = config.get("DataPath", "csv_path")
...@@ -130,7 +130,7 @@ def update_documents(app_api, collection): ...@@ -130,7 +130,7 @@ def update_documents(app_api, collection):
def delete_document(app_api, collection): def delete_document(app_api, collection):
@app_api.delete("/delete-document/{document_id}") @app_api.delete("/delete-document/{document_id}", tags=["delete document"])
async def delete_documents(document_id: int): async def delete_documents(document_id: int):
condition_data = {"id": document_id} condition_data = {"id": document_id}
deleted_one = collection.delete_one(condition_data) deleted_one = collection.delete_one(condition_data)
......
# importing libraries # importing libraries
from fastapi import FastAPI from fastapi import FastAPI
# from scripts.constants.app_configuration import csv_path from scripts.constants.app_configuration import csv_path
from scripts.constants.db_connection import db_connect from scripts.constants.db_connection import db_connect
from scripts.core.handlers.insert_data_into_db import insert_into_db from scripts.core.handlers.insert_data_into_db import insert_into_db
from scripts.core.handlers.operations import start_operations, view_documents, insert_document, update_documents, \ from scripts.core.handlers.operations import start_operations, view_documents, insert_document, update_documents, \
...@@ -20,7 +20,7 @@ async def root(): ...@@ -20,7 +20,7 @@ async def root():
start_operations(app) start_operations(app)
# Insert data from csv to database # Insert data from csv to database
data = extract_data("temp/data.csv") data = extract_data(csv_path)
db = db_connect() db = db_connect()
collection = create_collection(db) collection = create_collection(db)
insert_status = insert_into_db(collection, data) insert_status = insert_into_db(collection, data)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment