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）！