Create db connection global

[apptechxonia]

With reference to documentation example, I want to connect lambda with Mongodb ,

from fastapi import FastAPI, Body, status, Depends

from mangum import Mangum

from motor.motor_asyncio import AsyncIOMotorClient

from fastapi.responses import JSONResponse

from app.utility.config import MONGODB_URL, MAX_CONNECTIONS_COUNT, MIN_CONNECTIONS_COUNT, MAX_DB_THREADS_WAIT_COUNT, MAX_DB_THREAD_QUEUE_TIMEOUT_COUNT

application= FastAPI()

client = AsyncIOMotorClient(str(MONGODB_URL),

                                   maxPoolSize=MAX_CONNECTIONS_COUNT,

                                   minPoolSize=MIN_CONNECTIONS_COUNT,

                                   waitQueueMultiple = MAX_DB_THREADS_WAIT_COUNT,

                                   waitQueueTimeoutMS = MAX_DB_THREAD_QUEUE_TIMEOUT_COUNT )

async def get_database() -> AsyncIOMotorClient:

   

    return client

@application.post("/createStudent")

async def create_student(student = Body(...), db: AsyncIOMotorClient = Depends(get_database)):

    new_student = await db["college"]["students"].insert_one(student)

    created_student = await db["college"]["students"].find_one({"_id": new_student.inserted_id})

    return JSONResponse(status_code=status.HTTP_201_CREATED, content=created_student)

@application.post("/createTeacher")

async def create_teacher(teacher = Body(...), db: AsyncIOMotorClient = Depends(get_database)):

    new_teacher = await db["college"]["students"].insert_one(teacher)

    created_teacher = await db["college"]["students"].find_one({"_id": new_teacher.inserted_id})

    return JSONResponse(status_code=status.HTTP_201_CREATED, content=created_teacher)

handler = Mangum(application)

But every API request initiate new DB connection. How to cache or reuse Mongodb connection using Mangum ?

[Luc-Bertin]

Hello, same question here, see reference post here

btw @apptechxonia, how do you show it does initiate new DB connections (I'm pretty sure it does from the code, but I'm curious to know how can we/you prove it?)