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

Store segment and hour avg sizes per camera

Browse Source
This commit is contained in:
Nick Mowen 2022-09-25 09:39:56 -06:00
parent ad9227e0e6
commit c3387effe0
2 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
frigate/http.py
View File

@ -752,6 +752,7 @@ def recordings(camera_name):
Recordings.start_time, Recordings.start_time,
Recordings.end_time, Recordings.end_time,
Recordings.segment_size, Recordings.segment_size,
Recordings.duration,
Recordings.motion, Recordings.motion,
Recordings.objects, Recordings.objects,
) )

12
frigate/storage.py
View File

@ -19,7 +19,7 @@ class StorageMaintainer(threading.Thread):
self.name = "recording_cleanup" self.name = "recording_cleanup"
self.config = config self.config = config
self.stop_event = stop_event self.stop_event = stop_event
self.avg_segment_sizes = {} self.avg_segment_sizes: dict[str, dict] = {}
def calculate_camera_segment_sizes(self): def calculate_camera_segment_sizes(self):
"""Calculate the size of each cameras recording segments.""" """Calculate the size of each cameras recording segments."""
@ -27,12 +27,18 @@ class StorageMaintainer(threading.Thread):
if not self.config.cameras[camera].record.enabled: if not self.config.cameras[camera].record.enabled:
continue continue
self.avg_segment_sizes[camera] = ( avg_segment_size = round(
Recordings.select(fn.AVG(Recordings.segment_size)) Recordings.select(fn.AVG(Recordings.segment_size))
.where(Recordings.camera == camera) .where(Recordings.camera == camera)
.where(Recordings.segment_size != 0) .where(Recordings.segment_size != 0)
.scalar() .scalar(),
2,
) )
segment_duration = int(Recordings.select(Recordings.duration).where(Recordings.camera == camera).scalar())
self.avg_segment_sizes[camera] = {
"segment": avg_segment_size,
"hour": (3600 / segment_duration) * avg_segment_size
}
def run(self): def run(self):
# Check storage consumption every 5 minutes # Check storage consumption every 5 minutes