fastapi_mongo_non_blocking_example.py

fastapi_mongo_non_blocking_example.py

import uvicorn, asyncio
import motor.motor_asyncio
from fastapi import FastAPI
import pandas as pd

app = FastAPI()
client = motor.motor_asyncio.AsyncIOMotorClient()
db = client['MYDB']

def process_data(data):
    data = pd.DataFrame(data)
    data = data.query("mycolumn == 'somevalue'")
    return len(data)

@app.get("/")
async def test():
    documents = await db['mycollection'].find({}).to_list(length=None) # none = all documents
    loop = asyncio.get_event_loop()
    return await loop.run_in_executor(None, process_data, documents)

if __name__ == "__main__":
    uvicorn.run(app, host="0.0.0.0", port=8000)