Python 下载m3u8 (简易版多线程)


import requests
import os
import datetime
import threading

class xiazai():
    def __init__(self,url):
        self.url = url
        work_dir = os.getcwd()
        # print(work_dir)
        # 用来保存ts文件
        file_dir = os.path.join(work_dir, 'file_tmp')
        if not os.path.exists(file_dir):
            os.mkdir(file_dir)
        self.headers ={
            'user-agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_3) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/80.0.3987.116 Safari/537.36'
        }
        self.savefile(self.url)

    def savefile(self, file_url):

        r = requests.get(file_url, headers=self.headers)
        # 合成带有hls的m3u8地址
        if r.text.split('\n')[-1] == '':
            hls_mark = r.text.split('\n')[-2]  # 以防\n结尾
        else:
            hls_mark = r.text.split('\n')[-1]
        self.url_m3u8_hls = file_url.replace('index.m3u8', hls_mark)
        #file_m3u8 = url_m3u8_hls.split('/')[-1]
        self.duqu()
        #print(url_m3u8_hls)

    def duqu(self):
        r = requests.get(self.url_m3u8_hls, headers=self.headers).text
        text_bytes = r.split('\n')
        # 筛选以.ts结尾的行
        # 有些情况下可能是以其他格式的文件,比如png,下载后修改后缀即可
        # ts_name = [i for i in text_string if i.endswith('.ts')]
        self.ts_time = [i for i in text_bytes if i.startswith('#EXTINF')]
        #self.shijian(dm_time)
        #print(dm_time)
        self.ts_neirong = [i for i in text_bytes if not i.startswith('#')]
        self.ts_neirong.pop()
        self.threads = []
        self.threads.append(threading.Thread(target=self.xiazai))
        self.threads.append(threading.Thread(target=self.shijian))
        for t in self.threads:
            # print(t)
            t.start()
        #self.xiazai(url_m3u8_hls)
        # print(ts_neirong)
    def shijian(self):
        self.dm_time = 0
        for i in range(len(self.ts_time)):
            ts_time1 = self.ts_time[i].replace('#EXTINF:', '')
            ts_time2 = ts_time1.replace(',', '')
            self.dm_time = float(ts_time2) + self.dm_time
        shichang_time = str(datetime.timedelta(seconds=self.dm_time))
        print('视频时长:%s' % shichang_time)
    def xiazai(self):
        liebiao=[]
        for i in range(len(self.ts_neirong)):
            hls_mark = self.url_m3u8_hls.split('/')[-1]
            url_xiazai = self.url_m3u8_hls.replace(hls_mark, self.ts_neirong[i])
            liebiao.append(url_xiazai)
            #print(url_xiazai)
            # r = requests.get(url_xiazai, headers=self.headers)
            # with open('file_tmp/'+ts_neirong[i], 'wb') as f:
            # f.write(r.content)
            # f.close()
        x = self.bisector_list(liebiao, 10)
        self.xiancheng0=x[0]
        self.xiancheng1=x[1]
        self.xiancheng2=x[2]
        self.xiancheng3=x[3]
        self.xiancheng4=x[4]
        self.xiancheng5=x[5]
        self.xiancheng6=x[6]
        self.xiancheng7=x[7]
        self.xiancheng8=x[8]
        self.xiancheng9=x[9]
        self.threads2 = []
        self.threads2.append(threading.Thread(target=self.xiancheng_xiazai1))
        self.threads2.append(threading.Thread(target=self.xiancheng_xiazai2))
        self.threads2.append(threading.Thread(target=self.xiancheng_xiazai3))
        self.threads2.append(threading.Thread(target=self.xiancheng_xiazai4))
        self.threads2.append(threading.Thread(target=self.xiancheng_xiazai5))
        self.threads2.append(threading.Thread(target=self.xiancheng_xiazai6))
        self.threads2.append(threading.Thread(target=self.xiancheng_xiazai7))
        self.threads2.append(threading.Thread(target=self.xiancheng_xiazai8))
        self.threads2.append(threading.Thread(target=self.xiancheng_xiazai9))
        self.threads2.append(threading.Thread(target=self.xiancheng_xiazai10))

        for t in self.threads2:
            # print(t)
            t.start()


    def xiancheng_xiazai1(self):
        #print(self.xiancheng0)
        for i in self.xiancheng0:
            #print(i)
            r = requests.get(i, headers=self.headers)
            mingzi = i.split('/')[-1]
            with open('file_tmp/'+mingzi, 'wb') as f:
                f.write(r.content)
        f.close()

    def xiancheng_xiazai2(self):
        #print(self.xiancheng1)
        for i in self.xiancheng1:
            #print(i)
            r = requests.get(i, headers=self.headers)
            mingzi= i.split('/')[-1]
            with open('file_tmp/'+mingzi, 'wb') as f:
                f.write(r.content)
        f.close()

    def xiancheng_xiazai3(self):
        #print(self.xiancheng2)
        for i in self.xiancheng2:
            #print(i)
            r = requests.get(i, headers=self.headers)
            mingzi = i.split('/')[-1]
            with open('file_tmp/'+mingzi, 'wb') as f:
                f.write(r.content)
        f.close()

    def xiancheng_xiazai4(self):
        #print(self.xiancheng3)
        for i in self.xiancheng3:
            #print(i)
            r = requests.get(i, headers=self.headers)
            mingzi = i.split('/')[-1]
            with open('file_tmp/'+mingzi, 'wb') as f:
                f.write(r.content)
        f.close()


    def xiancheng_xiazai5(self):
        #print(self.xiancheng4)
        for i in self.xiancheng4:
        #print(i)
            r = requests.get(i, headers=self.headers)
            mingzi = i.split('/')[-1]
            with open('file_tmp/'+mingzi, 'wb') as f:
                f.write(r.content)
        f.close()


    def xiancheng_xiazai6(self):
        #print(self.xiancheng5)
        for i in self.xiancheng5:
        #print(i)
            r = requests.get(i, headers=self.headers)
            mingzi = i.split('/')[-1]
            with open('file_tmp/'+mingzi, 'wb') as f:
                f.write(r.content)
        f.close()


    def xiancheng_xiazai7(self):
        #print(self.xiancheng6)
        for i in self.xiancheng6:
        #print(i)
            r = requests.get(i, headers=self.headers)
            mingzi = i.split('/')[-1]
            with open('file_tmp/'+mingzi, 'wb') as f:
                f.write(r.content)
        f.close()


    def xiancheng_xiazai8(self):
        #print(self.xiancheng7)
        for i in self.xiancheng7:
        #print(i)
            r = requests.get(i, headers=self.headers)
            mingzi = i.split('/')[-1]
            with open('file_tmp/'+mingzi, 'wb') as f:
                f.write(r.content)
        f.close()


    def xiancheng_xiazai9(self):
        #print(self.xiancheng8)
        for i in self.xiancheng8:
        #print(i)
            r = requests.get(i, headers=self.headers)
            mingzi = i.split('/')[-1]
            with open('file_tmp/'+mingzi, 'wb') as f:
                f.write(r.content)
        f.close()


    def xiancheng_xiazai10(self):
        #print(self.xiancheng9)
        for i in self.xiancheng9:

        #print(i)
            r = requests.get(i, headers=self.headers)
            mingzi = i.split('/')[-1]
            with open('file_tmp/'+mingzi, 'wb') as f:
                f.write(r.content)
        f.close()


    def bisector_list(self,tabulation: list, num: int):
        """
        将列表平均分成几份
        :param tabulation: 列表
        :param num: 份数
        :return: 返回一个新的列表
        """
        new_list = []

        '''列表长度大于等于份数'''
        if len(tabulation) >= num:
            '''remainder:列表长度除以份数,取余'''
            remainder = len(tabulation) % num
            if remainder == 0:
                '''merchant:列表长度除以分数'''
                merchant = int(len(tabulation) / num)
                '''将列表平均拆分'''
                for i in range(1, num + 1):
                    if i == 1:
                        new_list.append(tabulation[:merchant])
                    else:
                        new_list.append(tabulation[(i - 1) * merchant:i * merchant])
                return new_list
            else:
                '''merchant:列表长度除以分数 取商'''
                merchant = int(len(tabulation) // num)
                '''remainder:列表长度除以份数,取余'''
                remainder = int(len(tabulation) % num)
                '''将列表平均拆分'''
                for i in range(1, num + 1):
                    if i == 1:
                        new_list.append(tabulation[:merchant])
                    else:
                        new_list.append(tabulation[(i - 1) * merchant:i * merchant])
                        '''将剩余数据的添加前面列表中'''
                        if int(len(tabulation) - i * merchant) <= merchant:
                            for j in tabulation[-remainder:]:
                                new_list[tabulation[-remainder:].index(j)].append(j)
                return new_list
        else:
            '''如果列表长度小于份数'''
            for i in range(1, len(tabulation) + 1):
                tabulation_subset = []
                tabulation_subset.append(tabulation[i - 1])
                new_list.append(tabulation_subset)
            return new_list

if __name__=='__main__':
    xiazai('http://iqiyi.cdn9-okzy.com/20200907/15137_ed25d8c5/index.m3u8')

速度很慢.  40m 5分钟  不加多线程 1小时。 可能我的m3u8不行,或者我电脑不行, 多线程是机械式的。  电脑好 可以多加几条。


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM