python利用ffmpeg实现视频流的下载,并分段保存
一段示例代码。self._running是线程运行参数,=TRUE;
get_random_ua()是生成一个user_agent,也可以写成固定字符串,例如“Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/94.0.4606.71 Safari/537.36 SE 2.X MetaSr 1.0”;
Splittimes 是分段的时长,单位"秒";
filename 不用解释,包含全路径;
注释掉的Splitsizes 是分段的大小,单位"字节";
while self._running:
now = datetime.datetime.now().strftime("%Y%m%d_%H%M%S")
print(datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S") ,f'第{i}次录制')
print(f'录制url:{url}')
houzhui=re.findall("\.\w+",url)[-1]
print(f'文件后缀名:{houzhui}')
filenameshort=now +houzhui
filename=filepath+'/'+filenameshort #os.path.join(filepath, filenameshort) #
print(url)
print("\r"," 分段录制视频中: ",filename, " 每录满: %d 分钟 存一个视频"%Splittime)
#logger.info(f'{filename}录制')
try:
logger.info(f'{filename}开始录制')
p = subprocess.check_output([
ffmpeg_path, "-y",
"-v","verbose",
"-rw_timeout","10000000", # 10s
"-loglevel","error",
"-hide_banner",
"-user_agent",get_random_ua(),
"-protocol_whitelist","rtmp,crypto,file,http,https,tcp,tls,udp,rtp",
"-thread_queue_size","1024",
"-analyzeduration","2147483647",
"-probesize","2147483647",
"-fflags","+discardcorrupt",
"-i",url,
"-bufsize","5000k",
"-map","0",
"-sn","-dn",
"-reconnect_delay_max","30","-reconnect_streamed","-reconnect_at_eof",
"-c:v","copy",
"-c:a","copy",
"-max_muxing_queue_size","64",
"-correct_ts_overflow","1",
"-f","mpegts",
#"-fs",str(Splitsizes),
"-t",str(Splittimes),
"{path}".format(path=filename),
], stderr = subprocess.STDOUT)
except subprocess.TimeoutExpired as time_e:
print(time_e)
logger.info(time_e)
time.sleep(5)
continue
except subprocess.CalledProcessError as call_e:
print(call_e.output.decode(encoding="utf-8"))
if 'NOT' in call_e.output.decode(encoding="utf-8").upper() or 'ERROR' in call_e.output.decode(encoding="utf-8").upper():
logger.info('直播结束')
logger.info( call_e.output.decode(encoding="utf-8"))
#sched2.shutdown(wait=False)
break
time.sleep(5)
continue
except Exception as e:
print(e)
logger.info(e)
if "error" in str(e): #Unknown error
logger.info('录制非正常结束2')
#sched2.shutdown(wait=False)
time.sleep(5)
continue
原文地址:https://blog.csdn.net/cc605523/article/details/140376578
免责声明:本站文章内容转载自网络资源,如本站内容侵犯了原著者的合法权益,可联系本站删除。更多内容请关注自学内容网(zxcms.com)!