if __name__=='__main__':
    url = 'http://91kj.vip/vodplay/180551-4-1.html'
    main(url)

def main(url):
    m3u8_f_url=get_m3u8_url(url)
    get_m3u8(m3u8_f_url)
    m3u8url = dow_m3u8(m3u8_f_url)
    asyncio.run(aio_download())

def get_m3u8_url(url):
    res = requests.get(url)
    obj = re.compile(r'"},"url":"(?P<uur>.*?)","url_next":',re.S)
    ul = obj.search(res.text).groups('uur')
    ul=clean(ul)
    return ul

def get_m3u8(url):
    res = requests.get(url)
    with open('first.m3u8',mode='wb') as f:
        f.write(res.content)

def dow_m3u8(url):
    with open('first.m3u8',mode='r') as f:
        for i in f:
            if i.startswith("#"):
                continue
            else:
                i.split()
                url_hou=i.split('/',3)[3]
                url_qian=url.split('index.m3u8')[0]
                urlre= url_qian+url_hou
                
    with open("second.m3u8",mode="wb") as f:
        hed = {
            'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/97.0.4692.71 Safari/537.36 Edg/97.0.1072.62',
        }
        resp = requests.get(urlre,headers=hed)
        f.write(resp.content)
    return urlre

def modify_text():
    with open('list.txt', "r+") as f:
        f.seek(0)
        f.truncate()

def write(list):
    with open ("list.txt",mode="a+") as f:
        f.write(list)
    
async def download_ts(url,name,session):
    async with session.get(url) as resp:
        async with aiofiles.open(f"lyb/{name}",mode='wb') as f:
            await f.write(await resp.content.read())
    print(f'{name}下載完畢')
    
async def aio_download():
    """執行非同步操作 """
    n = 1
    tasks = []
    async with aiohttp.ClientSession() as session:
        async with aiofiles.open('second.m3u8',mode='r',encoding='utf-8') as f:
            modify_text()
            async for line in f:
                    line = line.strip()
                    if line.startswith('#'):
                        continue
                    name = f"{n}.ts"
                    names = name+"\n"
                    write(names)
                    n += 1
                    task = asyncio.create_task(download_ts(line,name,session))
                    tasks.append(task)
            await asyncio.wait(tasks)

key_url = m3u8url.split('index.m3u8')[0]+"key.key"

（點選開啟）

def get_ket(url):
    res = requests.get(url)
    res.encoding="utf-8"
    return res.text

async def aio_dec(key):
    tasks=[]
    async with aiofiles.open("list.txt",mode="r") as f:
        async for i in f:
            i= i.strip()
            task = asyncio.create_task(dec_ts(i,key))
            tasks.append(task)
            
        await asyncio.wait(tasks)
            

async def dec_ts(name,key):
    aes = AES.new(key=key.encode('utf-8'),  IV=b"0000000000000000",mode=AES.MODE_CBC)
    async with aiofiles.open(f"lyb/{name}",mode="rb") as f1,\
        aiofiles.open(f"temp_lyb/{name}",mode="wb") as f2:
            
            bs = await f1.read()
            await f2.write(aes.decrypt(bs))
        
            print(f"{name}完成")

def make(list,name):
    s = '+'.join(list)
    os.system(f"cd temp_lyb & copy /b {s} {name}.mp4")
    print(f"over{name}")

def merge_ts():
    lst = []
    lst2 = []
    n=1
    with open("list.txt",mode="r",encoding="utf-8") as f:
        for i in f:
            i = i.strip()
            lst.append(f'{i}')
            if len(lst)==650:
                make(lst,n)
                n+=1
                lst = []
        make(lst,n)
        for j in range(n):
            j+=1
            lst2.append(f'{j}.mp4')
            make(lst2,'over')