Mirrors/blakeblackshear.frigate
1
0
Fork 0
mirror of https://github.com/blakeblackshear/frigate.git synced 2024-11-26 19:06:11 +01:00
Code Issues Projects Releases Wiki Activity

optimize checking recordings for events

Browse Source 
sorts events and recordings so you can avoid a cartesian product of checking all events against all recordings
This commit is contained in:
Blake Blackshear 2021-09-02 08:24:53 -05:00
parent a1e52c51b1
commit 8e1c15291d
1 changed files with 28 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
frigate/record.py
View File

@ -186,20 +186,38 @@ class RecordingCleanup(threading.Thread):
expire_date = min(min_end, expire_before) expire_date = min(min_end, expire_before)
# Get recordings to check for expiration # Get recordings to check for expiration
recordings: Recordings = Recordings.select().where( recordings: Recordings = (
Recordings.select()
.where(
Recordings.camera == camera, Recordings.camera == camera,
Recordings.end_time < expire_date, Recordings.end_time < expire_date,
) )
.order_by(Recordings.start_time.desc())
.objects()
)
# Get all the events to check against # Get all the events to check against
events: Event = Event.select().where( events: Event = (
Event.select()
.where(
Event.camera == camera, Event.end_time < expire_date, Event.has_clip Event.camera == camera, Event.end_time < expire_date, Event.has_clip
) )
.order_by(Event.start_time.desc())
.objects()
)
# loop over recordings and see if they overlap with any non-expired events # loop over recordings and see if they overlap with any non-expired events
event_start = 0
logger.debug(
f"Checking {len(recordings)} recordings against {len(events)} events"
)
for recording in recordings: for recording in recordings:
keep = False keep = False
for event in events: # since the events and recordings are sorted, we can skip events
# that start after the previous recording segment ended
for idx in range(event_start, len(events)):
event = events[idx]
# logger.debug(f"Checking event {event.id}")
if ( if (
( # event starts in this segment ( # event starts in this segment
event.start_time > recording.start_time event.start_time > recording.start_time
@ -217,6 +235,10 @@ class RecordingCleanup(threading.Thread):
keep = True keep = True
break break
# if the event starts after the current recording, skip it next time
if event.start_time > recording.end_time:
event_start = idx
# Delete recordings outside of the retention window # Delete recordings outside of the retention window
if not keep: if not keep:
Path(recording.path).unlink(missing_ok=True) Path(recording.path).unlink(missing_ok=True)