python 实现多线程下载m3u8格式视频并使用fmmpeg合并

python 实现多线程下载实现多线程下载m3u8格式视频并使用格式视频并使用fmmpeg合并合并

主要介绍了python 实现多线程下载m3u8格式视频，使用fmmpeg合并的实例代码,需要的朋友可以参考下

电影之类的长视频好像都用m3u8格式了，这就导致了多线程下载视频的意义不是很大，都是短视频，线不线程就没什么意义了嘛。

我们知道，m3u8的链接会下载一个文档，相当长，半小时的视频，应该有接近千行ts链接。

这些ts链接下载成ts文件，就是碎片化的视频，加以合并，就成了需要的视频。

那，即便网速很快，下几千行视频，效率也就低了，更何况还要合并。我就琢磨了一下午，怎么样才能多线程下载m3u8格式的视频呢？

先上代码，再说重难点：

import datetime

def down():

# m3u8链接

url = 'https://ali-video.acfun.cn/mediacloud/acfun/acfun_video/segment/3zf_GAW6nFMuDXrTLL89OZYOZ4mwxGoASH6UcZbsj1_6eAxUxtp3xm8wFmGMNOnZ.m3u8?auth_key=1573739375-474267152-0-a5aa2b6df4cb4168381bf8b04d88ddb1'

# 当ts文件链接不完整时，需拼凑

# 大部分网站可使用该方法拼接，部分特殊网站需单独拼接

base_url = re.split(r"[a-zA-Z0-9-_\.]+\.m3u8", url)[0]

# print(base_url)

resp = requests.get(url)

m3u8_text = resp.text

# print(m3u8_text)

if '.ts' in line:

if 'http' in line:

# print("ts>>", line)

ts_queue.put(line)

else:

line = base_url + line

ts_queue.put(line)

# print('ts>>',line)

filename = re.search('([a-zA-Z0-9-]+.ts)', line).group(1).strip()

# 一定要先写文件，因为线程的下载是无序的，文件无法按照

tt_name = threading.current_thread().getName()

while not ts_queue.empty():

url = ts_queue.get()

r = requests.get(url, stream=True)

filename = re.search('([a-zA-Z0-9-]+.ts)', url).group(1).strip()

with open('cache/' + filename, 'wb') as fp:

for chunk in r.iter_content(5242):

if chunk:

fp.write(chunk)

print(tt_name + " " + filename + ' 下载成功')

print('视频合并完成')

except:

print('合并失败')

if __name__ == '__main__':

name = input('请输入视频名称：')

start = datetime.datetime.now().replace(microsecond=0)

s,concatfile = down()

# print(s,concatfile)

threads = []

for i in range(15):

end = datetime.datetime.now().replace(microsecond=0)

print('下载耗时：' + str(end - start))

merge(concatfile,name)

over = datetime.datetime.now().replace(microsecond=0)

print('合并耗时：' + str(over - end))

效果图：

代码开始：自己输入视频名称（也可以去原网站爬名称）

查看下载耗时，fmmpeg开始合并：

合并耗时：

7分多钟，90个ts文件，接近40MB。两秒下载完成。