administrator/frigate
1
0
Fork 0
mirror of https://github.com/blakeblackshear/frigate.git synced 2026-02-15 07:35:27 +03:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

load sqlite_vec in main thread db

Browse Source
This commit is contained in:
Josh Hawkins 2024-10-04 13:23:46 -05:00
parent b31216da74
commit 5181ea7b3d
1 changed files with 19 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
frigate/app.py
View File

@ -9,6 +9,7 @@ from multiprocessing.synchronize import Event as MpEvent
from typing import Any, Optional from typing import Any, Optional
import psutil import psutil
import sqlite_vec
import uvicorn import uvicorn
from peewee_migrate import Router from peewee_migrate import Router
from playhouse.sqlite_ext import SqliteExtDatabase from playhouse.sqlite_ext import SqliteExtDatabase
@ -223,11 +224,8 @@ class FrigateApp:
def init_embeddings_manager(self) -> None: def init_embeddings_manager(self) -> None:
if not self.config.semantic_search.enabled: if not self.config.semantic_search.enabled:
self.embeddings = None
return return
# Create a client for other processes to use
self.embeddings = EmbeddingsContext()
embedding_process = util.Process( embedding_process = util.Process(
target=manage_embeddings, target=manage_embeddings,
name="embeddings_manager", name="embeddings_manager",
@ -266,6 +264,14 @@ class FrigateApp:
] ]
self.db.bind(models) self.db.bind(models)
if self.config.semantic_search.enabled:
# use existing db connection to load sqlite_vec extension
conn = self.db.connection()
conn.enable_load_extension(True)
sqlite_vec.load(conn)
conn.enable_load_extension(False)
logger.info(f"main connection: {self.db}")
def check_db_data_migrations(self) -> None: def check_db_data_migrations(self) -> None:
# check if vacuum needs to be run # check if vacuum needs to be run
if not os.path.exists(f"{CONFIG_DIR}/.exports"): if not os.path.exists(f"{CONFIG_DIR}/.exports"):
@ -277,6 +283,14 @@ class FrigateApp:
migrate_exports(self.config.ffmpeg, list(self.config.cameras.keys())) migrate_exports(self.config.ffmpeg, list(self.config.cameras.keys()))
def init_embeddings_client(self) -> None:
if not self.config.semantic_search.enabled:
self.embeddings = None
return
# Create a client for other processes to use
self.embeddings = EmbeddingsContext(self.db)
def init_external_event_processor(self) -> None: def init_external_event_processor(self) -> None:
self.external_event_processor = ExternalEventProcessor(self.config) self.external_event_processor = ExternalEventProcessor(self.config)
@ -467,7 +481,7 @@ class FrigateApp:
self.event_processor.start() self.event_processor.start()
def start_event_cleanup(self) -> None: def start_event_cleanup(self) -> None:
self.event_cleanup = EventCleanup(self.config, self.stop_event) self.event_cleanup = EventCleanup(self.config, self.stop_event, self.db)
self.event_cleanup.start() self.event_cleanup.start()
def start_record_cleanup(self) -> None: def start_record_cleanup(self) -> None:
@ -591,6 +605,7 @@ class FrigateApp:
self.init_go2rtc() self.init_go2rtc()
self.bind_database() self.bind_database()
self.check_db_data_migrations() self.check_db_data_migrations()
self.init_embeddings_client()
self.init_inter_process_communicator() self.init_inter_process_communicator()
self.init_dispatcher() self.init_dispatcher()
self.start_detectors() self.start_detectors()