mirror of
https://github.com/mwalbeck/podfox.git
synced 2025-04-24 13:34:03 +00:00
Merge branch 'progressbar'
This commit is contained in:
commit
16e560e952
3 changed files with 11 additions and 5 deletions
|
@ -39,6 +39,7 @@ import re
|
||||||
|
|
||||||
from email.utils import parsedate
|
from email.utils import parsedate
|
||||||
from time import time, mktime, gmtime, strftime, sleep
|
from time import time, mktime, gmtime, strftime, sleep
|
||||||
|
from tqdm import tqdm
|
||||||
|
|
||||||
CONFIGURATION = {}
|
CONFIGURATION = {}
|
||||||
|
|
||||||
|
@ -339,21 +340,24 @@ def download_single(folder, url, filename):
|
||||||
for i in range(connection_retries):
|
for i in range(connection_retries):
|
||||||
try:
|
try:
|
||||||
r = requests.get(url.strip(), stream=True, timeout=connection_timeout)
|
r = requests.get(url.strip(), stream=True, timeout=connection_timeout)
|
||||||
|
size = int(r.headers.get('content-length'))
|
||||||
|
progress = tqdm(total=size, unit="B", unit_scale=True)
|
||||||
with open(os.path.join(base, folder, filename), 'wb') as f:
|
with open(os.path.join(base, folder, filename), 'wb') as f:
|
||||||
for chunk in r.iter_content(chunk_size=1024**2):
|
for chunk in r.iter_content(1024):
|
||||||
f.write(chunk)
|
f.write(chunk)
|
||||||
|
progress.update(len(chunk))
|
||||||
except requests.Timeout:
|
except requests.Timeout:
|
||||||
if i == connection_retries-1:
|
if i == connection_retries-1:
|
||||||
print("Connection to server timed out")
|
tqdm.write("Connection to server timed out")
|
||||||
else:
|
else:
|
||||||
print("Connection timed out, retrying...")
|
tqdm.write("Connection timed out, retrying...")
|
||||||
sleep(1)
|
sleep(1)
|
||||||
continue
|
continue
|
||||||
except requests.ConnectionError:
|
except requests.ConnectionError:
|
||||||
if i == connection_retries-1:
|
if i == connection_retries-1:
|
||||||
print("Failed to establish connection with server")
|
tqdm.write("Failed to establish connection with server")
|
||||||
else:
|
else:
|
||||||
print("Connection failed, retrying...")
|
tqdm.write("Connection failed, retrying...")
|
||||||
sleep(1)
|
sleep(1)
|
||||||
continue
|
continue
|
||||||
else:
|
else:
|
||||||
|
|
|
@ -2,3 +2,4 @@ colorama==0.3.7
|
||||||
docopt==0.6.2
|
docopt==0.6.2
|
||||||
feedparser==5.2.1
|
feedparser==5.2.1
|
||||||
requests==2.11.1
|
requests==2.11.1
|
||||||
|
tqdm==4.14.0
|
1
setup.py
1
setup.py
|
@ -22,5 +22,6 @@ setup(name='podfox',
|
||||||
'docopt==0.6.2',
|
'docopt==0.6.2',
|
||||||
'feedparser==5.2.1',
|
'feedparser==5.2.1',
|
||||||
'requests==2.11.1',
|
'requests==2.11.1',
|
||||||
|
'tqdm==4.14.0',
|
||||||
],
|
],
|
||||||
)
|
)
|
||||||
|
|
Loading…
Add table
Reference in a new issue