fastapi/backend/apps/utils/mongo_util.py

from abc import ABC
from typing import Dict
from motor import motor_asyncio

class MongoUtil(ABC):
    
    def __init__(self):
        '''
        init mongo client
        '''
        super(MongoDB, self).__init__();
        self.client=motor_asyncio.AsyncIOMotorClient(connection_url)
        self.collection = client[""]

    async def update(self, record: Dict):
        return await self.collection.update_one(record)

    async def add(self, record: Dict):
        return await self.collection.insert_one(record)


    async def delete(self, record: Dict):
        # return await self.collection.
        pass