Method ainit_db

crawl4ai/async_database.py:15–32

(self)

        self.db_path = DB_PATH

    async def ainit_db(self):
        async with aiosqlite.connect(self.db_path) as db:
            await db.execute('''
                CREATE TABLE IF NOT EXISTS crawled_data (
                    url TEXT PRIMARY KEY,
                    html TEXT,
                    cleaned_html TEXT,
                    markdown TEXT,
                    extracted_content TEXT,
                    success BOOLEAN,
                    media TEXT DEFAULT "{}",
                    links TEXT DEFAULT "{}",
                    metadata TEXT DEFAULT "{}",
                    screenshot TEXT DEFAULT ""
                )
            ''')
            await db.commit()
        await self.update_db_schema()

    async def update_db_schema(self):
        async with aiosqlite.connect(self.db_path) as db: