schulischer-schabernack/site
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Encode different episodes simultaneously

Browse source 
This results in less nice log output, but if it’s faster then who cares?
This commit is contained in:
Simon Bruder 2021-12-01 15:48:29 +01:00
parent ce403a97a3
commit 4a6813d33a
Signed by: simon
GPG key ID: 8D3C82F9F309F8EC
1 changed files with 8 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
encode.py
View file

@ -1,7 +1,8 @@
#!/usr/bin/env python3 #!/usr/bin/env python3
import base64 import base64
import concurrent.futures
import multiprocessing
import os import os
import threading
import xml.etree.ElementTree as ET import xml.etree.ElementTree as ET
from datetime import datetime from datetime import datetime
from subprocess import run from subprocess import run
@ -77,9 +78,9 @@ def encode_episode(podcast, episode, format):
audio.save() audio.save()
print(f" {format}", end="", flush=True) print(f"[✔️] {episode['file_base']}.{format}")
else: else:
print(f" ({format})", end="", flush=True) print(f"[⏭️] {episode['file_base']}.{format}")
os.makedirs("static/episodes", exist_ok=True) os.makedirs("static/episodes", exist_ok=True)
@ -95,6 +96,8 @@ podcast = {
"poster": "static" + urlparse(channel.find("image").find("url").text).path, "poster": "static" + urlparse(channel.find("image").find("url").text).path,
} }
pool = concurrent.futures.ThreadPoolExecutor(max_workers=multiprocessing.cpu_count())
for item in channel.findall("item"): for item in channel.findall("item"):
episode = { episode = {
"title": item.find("title").text, "title": item.find("title").text,
@ -114,18 +117,7 @@ for item in channel.findall("item"):
)[0], )[0],
} }
print(episode["file_base"], end="", flush=True)
threads = []
for format in common.FORMATS.items(): for format in common.FORMATS.items():
thread = threading.Thread( pool.submit(encode_episode, podcast, episode, format)
target=encode_episode, args=(podcast, episode, format), daemon=True
)
thread.start()
threads.append(thread)
for thread in threads: pool.shutdown(wait=True)
thread.join()
print()