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

add debug logging

Browse Source
This commit is contained in:
Josh Hawkins 2024-11-06 10:54:18 -06:00
parent 95561c2939
commit c0e9628760
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
frigate/events/cleanup.py
View File

@ -110,6 +110,7 @@ class EventCleanup(threading.Thread):
.namedtuples() .namedtuples()
.iterator() .iterator()
) )
logger.debug(f"{len(expired_events)} events can be expired")
# delete the media from disk # delete the media from disk
for expired in expired_events: for expired in expired_events:
media_name = f"{expired.camera}-{expired.id}" media_name = f"{expired.camera}-{expired.id}"
@ -140,6 +141,9 @@ class EventCleanup(threading.Thread):
for batch in query.iterator(): for batch in query.iterator():
events_to_update.extend([event.id for event in batch]) events_to_update.extend([event.id for event in batch])
if len(events_to_update) >= CHUNK_SIZE: if len(events_to_update) >= CHUNK_SIZE:
logger.debug(
f"Updating {update_params} for {len(events_to_update)} events"
)
Event.update(update_params).where( Event.update(update_params).where(
Event.id << events_to_update Event.id << events_to_update
).execute() ).execute()
@ -147,6 +151,9 @@ class EventCleanup(threading.Thread):
# Update any remaining events # Update any remaining events
if events_to_update: if events_to_update:
logger.debug(
f"Updating clips/snapshots attribute for {len(events_to_update)} events"
)
Event.update(update_params).where( Event.update(update_params).where(
Event.id << events_to_update Event.id << events_to_update
).execute() ).execute()
@ -216,6 +223,7 @@ class EventCleanup(threading.Thread):
# update the clips attribute for the db entry # update the clips attribute for the db entry
for i in range(0, len(events_to_update), CHUNK_SIZE): for i in range(0, len(events_to_update), CHUNK_SIZE):
batch = events_to_update[i : i + CHUNK_SIZE] batch = events_to_update[i : i + CHUNK_SIZE]
logger.debug(f"Updating {update_params} for {len(batch)} events")
Event.update(update_params).where(Event.id << batch).execute() Event.update(update_params).where(Event.id << batch).execute()
return events_to_update return events_to_update
@ -243,9 +251,11 @@ class EventCleanup(threading.Thread):
.iterator() .iterator()
) )
events_to_delete = [e.id for e in events] events_to_delete = [e.id for e in events]
logger.debug(f"Found {len(events_to_delete)} events that can be expired")
if len(events_to_delete) > 0: if len(events_to_delete) > 0:
for i in range(0, len(events_to_delete), CHUNK_SIZE): for i in range(0, len(events_to_delete), CHUNK_SIZE):
chunk = events_to_delete[i : i + CHUNK_SIZE] chunk = events_to_delete[i : i + CHUNK_SIZE]
logger.debug(f"Deleting {len(chunk)} events from the database")
Event.delete().where(Event.id << chunk).execute() Event.delete().where(Event.id << chunk).execute()
if self.config.semantic_search.enabled: if self.config.semantic_search.enabled: