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

don't overwrite segments that already exist (#3995)

Browse Source
This commit is contained in:
Blake Blackshear 2022-10-01 18:11:29 -05:00 committed by GitHub
parent 10783fec49
commit 8669c29e3d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 24 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
frigate/record.py
View File

@ -276,28 +276,31 @@ class RecordingMaintainer(threading.Thread):
file_path = os.path.join(directory, file_name) file_path = os.path.join(directory, file_name)
try: try:
start_frame = datetime.datetime.now().timestamp() if not os.path.exists(file_path):
# copy then delete is required when recordings are stored on some network drives start_frame = datetime.datetime.now().timestamp()
shutil.copyfile(cache_path, file_path) # copy then delete is required when recordings are stored on some network drives
logger.debug( shutil.copyfile(cache_path, file_path)
f"Copied {file_path} in {datetime.datetime.now().timestamp()-start_frame} seconds." logger.debug(
) f"Copied {file_path} in {datetime.datetime.now().timestamp()-start_frame} seconds."
os.remove(cache_path) )
rand_id = "".join( rand_id = "".join(
random.choices(string.ascii_lowercase + string.digits, k=6) random.choices(string.ascii_lowercase + string.digits, k=6)
) )
Recordings.create( Recordings.create(
id=f"{start_time.timestamp()}-{rand_id}", id=f"{start_time.timestamp()}-{rand_id}",
camera=camera, camera=camera,
path=file_path, path=file_path,
start_time=start_time.timestamp(), start_time=start_time.timestamp(),
end_time=end_time.timestamp(), end_time=end_time.timestamp(),
duration=duration, duration=duration,
motion=motion_count, motion=motion_count,
# TODO: update this to store list of active objects at some point # TODO: update this to store list of active objects at some point
objects=active_count, objects=active_count,
) )
else:
logger.warning(f"Ignoring segment because {file_path} already exists.")
os.remove(cache_path)
except Exception as e: except Exception as e:
logger.error(f"Unable to store recording segment {cache_path}") logger.error(f"Unable to store recording segment {cache_path}")
Path(cache_path).unlink(missing_ok=True) Path(cache_path).unlink(missing_ok=True)