dd_cnvrt.py

from functools import partial
from multiprocessing.dummy import Pool as ThreadPool
import os
import sys
import glob

#cat index-f2-v1-a1.m3u8 | sed 's|https://p16-tiktok-ads-sg.tiktokcdn.com/obj/ad-site-i18n-sg|dhm|g' > dhm.m3u8

dir_nm=sys.argv[1]
def cnvrt(frag_id):
    os.system(f"mv {frag_id} {frag_id}.mp4")
    os.system(f"dd if={frag_id}.mp4 of={frag_id} ibs=70 skip=1")
    #os.system(f"rm {frag_id}.mp4")

frags=glob.glob(f"{dir_nm}/*")
print("No. of Fragments", len(frags))
#os.system(f"mkdir {path}")
"""for i in seq_range:
    os.system(f"wget -t 5 --connect-timeout=30 --read-timeout=40 {url}/sq/{i} -O {path}/{i}.ts")"""
pool = ThreadPool(15)
pool.map(cnvrt, frags)
pool.close()
pool.join()