spider/Douyin_TikTok_Download_API
1
0
Fork 0
mirror of https://github.com/Evil0ctal/Douyin_TikTok_Download_API.git synced 2025-04-16 16:07:12 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #571 from hadwinfu/fix/download

Browse Source 
Fix: 自动清理未完成的文件
This commit is contained in:
Evil0ctal 2025-03-03 22:01:18 -08:00 committed by GitHub
commit 774b6b2890
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
app/api/endpoints/download.py
View File

@ -28,11 +28,10 @@ async def fetch_data(url: str, headers: dict = None):
return response
# 下载视频专用
async def fetch_data_stream(url: str, headers: dict = None, file_path: str = None):
async def fetch_data_stream(url: str, request:Request , headers: dict = None, file_path: str = None):
headers = {
'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/91.0.4472.124 Safari/537.36'
} if headers is None else headers.get('headers')
async with httpx.AsyncClient() as client:
# 启用流式请求
async with client.stream("GET", url, headers=headers) as response:
@ -41,8 +40,12 @@ async def fetch_data_stream(url: str, headers: dict = None, file_path: str = Non
# 流式保存文件
async with aiofiles.open(file_path, 'wb') as out_file:
async for chunk in response.aiter_bytes():
if await request.is_disconnected():
print("客户端断开连接，清理未完成的文件")
await out_file.close()
os.remove(file_path)
return False
await out_file.write(chunk)
return True
@router.get("/download", summary="在线下载抖音|TikTok视频/图片/Online download Douyin|TikTok video/image")
@ -122,10 +125,10 @@ async def download_file_hybrid(request: Request,
__headers = await HybridCrawler.TikTokWebCrawler.get_tiktok_headers() if platform == 'tiktok' else await HybridCrawler.DouyinWebCrawler.get_douyin_headers()
# response = await fetch_data(url, headers=__headers)
is_successful = await fetch_data_stream(url, headers=__headers, file_path=file_path)
if not is_successful:
success = await fetch_data_stream(url, request, headers=__headers, file_path=file_path)
if not success:
raise HTTPException(
status_code=400,
status_code=500,
detail="An error occurred while fetching data"
)