Compare commits
2 commits
eec8482df3
...
af5a7a4b17
Author | SHA1 | Date | |
---|---|---|---|
af5a7a4b17 | |||
b421cb3e32 |
1 changed files with 55 additions and 48 deletions
|
@ -179,6 +179,7 @@ def exec_recorder(stream_id, stream_name, stream_hls_url):
|
|||
video_output = f'{rec_path}/live/{video_file}'
|
||||
thumb_output = f'{rec_path}/live/{thumb_file}'
|
||||
|
||||
try:
|
||||
# Record a mp4 file
|
||||
ffmpeg = (
|
||||
FFmpeg()
|
||||
|
@ -191,8 +192,13 @@ def exec_recorder(stream_id, stream_name, stream_hls_url):
|
|||
def on_progress(progress: Progress):
|
||||
print(progress)
|
||||
ffmpeg.execute()
|
||||
logger_job.warning(f'Recording {video_file} finished.')
|
||||
logger_job.warning(f'Recording of {video_file} finished.')
|
||||
|
||||
except Exception as joberror:
|
||||
logger_job.error(f'Recording of {video_file} failed!')
|
||||
logger_job.error(joberror)
|
||||
|
||||
else:
|
||||
# Show Metadata
|
||||
ffmpeg_metadata = (
|
||||
FFmpeg(executable="ffprobe")
|
||||
|
@ -226,6 +232,7 @@ def exec_recorder(stream_id, stream_name, stream_hls_url):
|
|||
os.rename(f'{video_output}', f'{rec_path}/vod/{video_file}')
|
||||
os.rename(f'{thumb_output}', f'{rec_path}/thumb/{thumb_file}')
|
||||
|
||||
finally:
|
||||
# Reset the rechead
|
||||
time.sleep(5)
|
||||
rechead = {}
|
||||
|
|
Loading…
Reference in a new issue