github/XHS_Downloader
1
0
Fork 0
mirror of https://github.com/JoeanAmier/XHS-Downloader.git synced 2026-03-22 06:57:16 +08:00
Code Issues Packages Projects Releases Wiki Activity

perf(download.py): 修复下载文件频繁提示失败的问题

Browse Source 
Closes #170
Closes #182
Closes #185
This commit is contained in:
JoeanAmier
2024-10-20 21:35:12 +08:00
parent 8979ba8e25
commit bc436682fb
2 changed files with 31 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

44
source/application/download.py
View File

@@ -171,26 +171,27 @@ class Download:
):
async with self.SEMAPHORE:
headers = self.headers.copy()
try:
length, suffix = await self.__head_file(
url,
headers,
format_,
)
except HTTPError as error:
logging(
log,
self.message(
"网络异常，{0} 请求失败，错误信息: {1}").format(name, repr(error)),
ERROR,
)
# logging(
# log,
# f"{url} Head Headers: {headers.get("Range")}",
# WARNING,
# )
return False
temp = self.temp.joinpath(f"{name}.{suffix}")
# try:
# length, suffix = await self.__head_file(
# url,
# headers,
# format_,
# )
# except HTTPError as error:
# logging(
# log,
# self.message(
# "网络异常，{0} 请求失败，错误信息: {1}").format(name, repr(error)),
# ERROR,
# )
# # logging(
# # log,
# # f"{url} Head Headers: {headers.get("Range")}",
# # WARNING,
# # )
# return False
# temp = self.temp.joinpath(f"{name}.{suffix}")
temp = self.temp.joinpath(f"{name}.{format_}")
self.__update_headers_range(headers, temp, )
try:
async with self.client.stream("GET", url, headers=headers, ) as response:
@@ -210,7 +211,8 @@ class Download:
temp,
path,
name,
suffix,
# suffix,
format_,
log,
)
self.manager.move(temp, real)