{"id":11668,"date":"2026-01-15T11:36:18","date_gmt":"2026-01-15T10:36:18","guid":{"rendered":"https:\/\/spgoo.org\/?page_id=11668"},"modified":"2026-01-15T12:30:32","modified_gmt":"2026-01-15T11:30:32","slug":"fastapi-beanie-mongodb","status":"publish","type":"page","link":"https:\/\/spgoo.org\/?page_id=11668","title":{"rendered":"FastAPI — beanie — Mongodb"},"content":{"rendered":"\n

FastAPI — beanie — MongoDB<\/span> <\/h2>\n\n\n\n

Description du couplage entre le service web et la base de donn\u00e9es : <\/p>\n\n\n\n

Lien vers la documentation de beanie<\/a> : <\/p>\n\n\n\n

D\u00e9veloppement du module de database avec les interfaces d\u00e9di\u00e9es pour les diff\u00e9rentes op\u00e9rations souhait\u00e9es de manipulation des donn\u00e9es dans le cadre du projet de r\u00e9trosynth\u00e8se. dans ce projet on souhaite stocker dans un syst\u00e8me MongoDB<\/span> deux types de donn\u00e9es, les informations sur la r\u00e9trosynth\u00e8se (le smile, date, la r\u00e9f\u00e9rence interne et nb_routes) et les commentaires sur chaque solution trouv\u00e9e (date, texte du commentaire). Ces diff\u00e9rentes informations seront stock\u00e9es dans une collection d\u00e9di\u00e9e : retrosyntheses et comments. Donc les op\u00e9rations \u00e0 r\u00e9aliser couvrent les aspects classiques d’un CRUD.<\/p>\n\n\n\n

Exemple de module database : CRUD <\/p>\n\n\n\n

from beanie import init_beanie, PydanticObjectId\nfrom beanie.operators import In, RegEx<\/strong>\nfrom motor.motor_asyncio import AsyncIOMotorClient\nfrom pydantic import BaseModel\nfrom pydantic_settings import BaseSettings\nfrom typing import Any, List, Optional\nfrom models.retrosynthese import Retrosynthese\nfrom models.comments import CommentDoc\n\nclass Settings(BaseSettings):\n    DATABASE_URL: Optional[str] = None\n    SECRET_KEY: Optional[str] = None\n    async def initialize_database(self):\n        client = AsyncIOMotorClient(self.DATABASE_URL)\n        await init_beanie(\n        database=client.get_default_database(),document_models=[Retrosynthese, CommentDoc])\n    class Config:\n        env_file = \".env\"\n\nclass Database:\n    def __init__(self, model):\n        self.model = model\n    async def save(self, document) -> None:\n        await document.create()\n        return\n    async def get(self, id: PydanticObjectId) -> Any:\n        doc = await self.model.get(id)\n        if doc:\n            return doc\n        return False\n    async def getOne(self, id:str )->Any:\n        docs = await self.model.find_one(self.model.identifiant == id)\n        return docs\n    async def getOneSmile(self, smile:str )->Any:\n        docs = await self.model.find_one(self.model.smile == smile)\n        return docs\n    async def get_allF(self, filtre: str) -> List[Any]:\n        docs = await self.model.find(RegEx<\/strong>(self.model.identifiant,filtre)).to_list()\n        return docs\n    async def get_all(self) -> List[Any]:\n        docs = await self.model.find_all().to_list()\n        return docs\n    async def update(self, id: PydanticObjectId, body: BaseModel) -> Any:\n        doc_id = id\n        des_body = body.dict()\n        des_body = {k:v for k,v in des_body.items() if v is not None}\n        update_query = {\"$set\": {\n            field: value for field, value in \n            des_body.items()\n        }}\n        doc = await self.get(doc_id)\n        if not doc:\n            return False\n        await doc.update(update_query)\n        return doc\n    async def delete(self, id: PydanticObjectId) -> bool:\n        doc = await self.get(id)\n        if not doc:\n            return False\n        await doc.delete()\n        return True<\/code><\/pre>\n\n\n\n
Explications : il est important pour des manipulations classiques d’ins\u00e9rer beanie.operator qui nous permettra d’acc\u00e9der \u00e0 des fonctions sp\u00e9cifiques pour la mise en place de filtre. Dans cette classe, on a mis en place la g\u00e9n\u00e9ricit\u00e9 des mod\u00e8les utilis\u00e9s dans le projet. Ce qui permet d’avoir les m\u00eames fonctions pour les diff\u00e9rents mod\u00e8les. <\/p>\n\n\n\n
Explications de la partie initialize de la database : <\/p>\n\n\n\n
async def initialize_database(self):\n        client = AsyncIOMotorClient(self.DATABASE_URL)\n        await init_beanie(\n        database=client.get_default_database(),\n                      document_models=[Retrosynthese, CommentDoc])<\/code><\/pre>\n\n\n\n
Dans l’initialisation de la database, on pr\u00e9cise les mod\u00e8les de donn\u00e9es que l’on souhaite manipuler. Ce qui dans le code sera d\u00e9finie par l’instruction suivante : <\/p>\n\n\n\n
    \n
  • retro_database=Database(Retrosynthese)  # permet d’ouvrir un descripteur sur la collection retrosynthese<\/li>\n\n\n\n
  • comments_database=Database(CommentDoc) # permet d’ouvrir un descripteur sur la collection CommenDoc<\/li>\n<\/ul>\n\n\n\n
    Voir les mod\u00e8les <\/summary>\n
    <\/p>\n\n\n\n
    class Retrosynthese(Document):\n    identifiant: str\n    date: datetime\n    smile: str\n    nbroutes: int\n    class Settings:\n       name=\"retrosynthese\"\n    class Config:\n        json_schema_extra = {\n            \"example\": {\n                \"identifiant\": \"74017a01-ffdb-42fe-80ba-ad77f2fe2750\",\n                \"date\":\"01\/01\/2026\",\n                \"smile\": \"O=C(O)N1Cc2ccc(-c3cnc4cnccn34)cc2C1\",\n                \"nbroutes\": 0\n            }\n        }\nclass CommentDoc(Document):\n    identifiant: str\n    date: datetime\n    texte: str\n    class Settings:\n       name=\"comments\"\n    class Config:\n        json_schema_extra = {\n            \"example\": {\n                \"identifiant\": \"74017a01-ffdb-42fe-80ba-ad77f2fe2750_001\",\n                \"date\":datetime.now(),\n                \"texte\": \"commentaires \",\n            }\n        }<\/code><\/pre>\n<\/details>\n\n\n\n
    Explications des m\u00e9thodes associ\u00e9es \u00e0 cette classe database et l’utilisation des op\u00e9rateurs : l’attribut Settings de la classe du mod\u00e8le permet d’indiquer la collection cibl\u00e9e qui va contenir les donn\u00e9es. <\/p>\n\n\n\n
    Exemple de mise en place d\u2019agr\u00e9gation <\/p>\n