Files
MediaFusion/db/database.py
T
2023-11-13 21:35:23 +05:30

29 lines
660 B
Python

import motor.motor_asyncio
from beanie import init_beanie
from db.config import settings
from db.models import (
MediaFusionSeriesMetaData,
MediaFusionMovieMetaData,
Streams,
TVStreams,
MediaFusionTVMetaData,
)
async def init():
# Create Motor client
client = motor.motor_asyncio.AsyncIOMotorClient(settings.mongo_uri)
# Init beanie with the Product document class
await init_beanie(
database=client.mediafusion,
document_models=[
MediaFusionMovieMetaData,
MediaFusionSeriesMetaData,
Streams,
TVStreams,
MediaFusionTVMetaData,
],
)