python多线程下载m3u8，解密并使用ffmpeg合并ts（解决命令调用ffmpeg报错乱码）

谁借莪１个温暖的怀抱￠ 2021-09-09 06:30 1257阅读 0赞

**python调用ffmpeg报错**  
原本我已经安装ffmpeg并且配置环境变量，可以在命令行使用命令但是在pycharm中通过python调用

command = 'ffmpeg -y -f concat -i %s -crf 18 -ar 48000 -vcodec libx264 -c:a aac -r 25 -g 25 -keyint_min 25 -strict -2 %s' % (concatfile, path)
    os.system(command)

却还是报错“‘ffmpeg’ �����ڲ����ⲿ���Ҳ���ǿ����еĳ���  
���������ļ���” 应该是报的“‘ffmpeg’ 不是内部或外部命令，也不是可运行的程序或批处理文件。”错误  
修改为：

command = 'E:/utils/ffmpeg/bin/ffmpeg -y -f concat -i %s -crf 18 -ar 48000 -vcodec libx264 -c:a aac -r 25 -g 25 -keyint_min 25 -strict -2 %s' % (concatfile, path)
    os.system(command)

解决报错问题，由此看来**需要添加完整路径**

## 1.获取m3u8文件，读出ts链接，并写入文档 ##

def down():
        # m3u8链接
        url = 'https://vod6.wenshibaowenbei.com/20210309/2nFyXAZv/1000kb/hls/index.m3u8'
        # 当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)
        # 按行拆分m3u8文档
        ts_queue = Queue(10000)
        lines = m3u8_text.split('\n')
        # 找到文档中含有ts字段的行
        concatfile = 'cache/' + "s" + '.txt'
        for line in lines:
            # 匹配key
            if '.key' in line:
                k = re.compile(r"\"(.*?)\"") # key的正则匹配
                if 'http' in line:
                    key_url = k.findall(line)[0]# key的url
                    print("key1>>", key_url)
                else:
                    key_url = base_url + k.findall(line)[0]# key的url
                    print('key2>>',key_url)
                global key_data
                key_data=requests.get(key_url).content
                print('key_data>>',key_data)
            # 匹配ts
            。。。。。。。。。。。。。。。。
    
        return ts_queue,concatfile

## 2.线程模式，执行线程下载 ##

# 线程模式，执行线程下载
    def run(ts_queue):
        tt_name = threading.current_thread().getName()
        while not ts_queue.empty():
            url = ts_queue.get()
            ts = requests.get(url).content
            。。。。。。。。
            filename = re.search('([a-zA-Z0-9-]+.ts)', url).group(1).strip()
    
            if len(key_data): # AES 解密
                cryptor = AES.new(key_data, AES.MODE_CBC, key_data)
                with open('cache/' + filename, 'wb') as f:
                    f.write(cryptor.decrypt(ts))
                    print(tt_name + " " + filename + ' 解密下载成功')
            else:
                with open('cache/' + filename, 'wb') as f:
                    f.write(ts)
                    print(tt_name + " " + filename + ' 下载成功')

## 3.添加线程 ##

for i in range(15):
            t = threading.Thread(target=run, name='th-'+str(i), kwargs={ 'ts_queue': s})
            threads.append(t)

这是运行效果，**ts合并的MP4文件已框出**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjQwODY0OA_size_16_color_FFFFFF_t_70]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjQwODY0OA_size_16_color_FFFFFF_t_70]: /images/20210813/cdd943510b8041efbaaaeefad999b327.png