同步下载云盘高码率新剧，避免在线播放卡顿

最近使用tg2drive自动追剧到云盘，但是对于码率比较高的电视剧在观看时会很卡，几乎一秒一卡，于是有了本脚本的出现。


通过监控tg2drive生成的strm文件夹，通过关键词匹配下载指定电视剧，实现观看时不再卡顿，自动跳过已下载文件，由于监控的是生成到本地的strm文件，因此全程无云盘风控风险，扫描间隔在青龙面板配置想多短就多短。

对于其他strm方案只要strm内容是http直链均可正常使用，如果需要的人多也可以改一版webdav挂载方案。

至于为什么使用青龙面板而不是发一个docker，一来功能简单，二来实在是内存不够了

1. #!/usr/bin/env python3
   
2. """
   
3. 青龙面板定时脚本：扫描 strm 文件夹，下载关键词匹配的文件，保持目录结构
   
4. """
   
5. 
   
6. import os
   
7. import re
   
8. import time
   
9. import logging
   
10. import shutil
    
11. from urllib.parse import unquote, urlparse
    
12. from pathlib import Path
    
13. 
    
14. import requests
    
15. 
    
16. # ---------- 配置（根据实际情况修改）----------
    
17. STRM_DIR = "/volume1/docker/tg2drive/strm/123云盘/library/剧集"
    
18. DOWNLOAD_DIR = "/volume5/workspace/云盘下载"
    
19. KEYWORDS = ["小芳"]          # 文件名包含任意一个关键词即下载
    
20. RECURSIVE = True             # 是否递归扫描子目录
    
21. DOWNLOAD_TIMEOUT = 300       # 下载超时（秒）
    
22. RETRY_TIMES = 3              # 重试次数
    
23. # --------------------------------------------
    
24. 
    
25. logging.basicConfig(
    
26.     level=logging.INFO,
    
27.     format='%(asctime)s - %(levelname)s - %(message)s'
    
28. )
    
29. logger = logging.getLogger(__name__)
    
30. 
    
31. def ensure_dir(path):
    
32.     """确保目录存在"""
    
33.     os.makedirs(path, exist_ok=True)
    
34. 
    
35. def extract_filename_from_url(url):
    
36.     """从 URL 中提取文件名"""
    
37.     parsed = urlparse(url)
    
38.     path = unquote(parsed.path)
    
39.     filename = os.path.basename(path)
    
40.     if not filename:
    
41.         # 尝试从查询参数中提取（某些链接带 filename 参数）
    
42.         query = parsed.query
    
43.         match = re.search(r'filename=([^&]+)', query)
    
44.         if match:
    
45.             filename = unquote(match.group(1))
    
46.     return filename
    
47. 
    
48. def should_download(filename):
    
49.     """根据关键词判断是否应该下载"""
    
50.     if not filename:
    
51.         return False
    
52.     for kw in KEYWORDS:
    
53.         if kw in filename:
    
54.             return True
    
55.     return False
    
56. 
    
57. def download_file(url, dest_path):
    
58.     """下载文件到指定路径，带重试（每10%打印一次进度）"""
    
59.     for attempt in range(1, RETRY_TIMES + 1):
    
60.         try:
    
61.             logger.info(f"开始下载 [{attempt}/{RETRY_TIMES}]: {dest_path.name}")
    
62.             with requests.get(url, stream=True, timeout=DOWNLOAD_TIMEOUT) as r:
    
63.                 r.raise_for_status()
    
64.                 total_size = int(r.headers.get('content-length', 0))
    
65.                 temp_path = str(dest_path) + ".tmp"
    
66.                 with open(temp_path, 'wb') as f:
    
67.                     downloaded = 0
    
68.                     last_percent = -1
    
69.                     for chunk in r.iter_content(chunk_size=8192):
    
70.                         if chunk:
    
71.                             f.write(chunk)
    
72.                             downloaded += len(chunk)
    
73.                             if total_size:
    
74.                                 percent = int((downloaded / total_size) * 100)
    
75.                                 if percent >= last_percent + 10:
    
76.                                     logger.info(f"下载进度: {dest_path.name} {percent}%")
    
77.                                     last_percent = percent
    
78.                 shutil.move(temp_path, str(dest_path))
    
79.                 logger.info(f"下载完成: {dest_path.name} (大小: {total_size} bytes)")
    
80.                 return True
    
81.         except Exception as e:
    
82.             logger.error(f"下载失败 (尝试 {attempt}): {e}")
    
83.             temp_path = str(dest_path) + ".tmp"
    
84.             if os.path.exists(temp_path):
    
85.                 os.remove(temp_path)
    
86.             if attempt == RETRY_TIMES:
    
87.                 logger.error(f"下载最终失败: {dest_path.name}")
    
88.                 return False
    
89.             time.sleep(2 ** attempt)
    
90.     return False
    
91.    
    
92. def process_strm_file(strm_path):
    
93.     """
    
94.     处理单个 strm 文件
    
95.     返回：
    
96.         1  = 下载成功
    
97.         0  = 文件已存在，跳过
    
98.         -1 = 下载失败
    
99.         -2 = 关键词不匹配，跳过
    
100.     """
     
101.     # 读取 URL
     
102.     try:
     
103.         with open(strm_path, 'r', encoding='utf-8') as f:
     
104.             url = f.readline().strip()
     
105.     except Exception as e:
     
106.         logger.error(f"读取 strm 文件失败 {strm_path}: {e}")
     
107.         return -1
     
108. 
     
109.     if not url:
     
110.         logger.warning(f"strm 文件内容为空: {strm_path}")
     
111.         return -1
     
112. 
     
113.     # 提取文件名
     
114.     filename = extract_filename_from_url(url)
     
115.     if not filename:
     
116.         filename = Path(strm_path).stem
     
117.         logger.warning(f"无法从 URL 提取文件名，使用 strm 文件名: {filename}")
     
118. 
     
119.     # 关键词过滤
     
120.     if not should_download(filename):
     
121.         return -2  # 关键词不匹配
     
122. 
     
123.     # 计算目标路径
     
124.     rel_path = os.path.relpath(strm_path, STRM_DIR)
     
125.     rel_dir = os.path.dirname(rel_path)
     
126.     target_dir = Path(DOWNLOAD_DIR) / rel_dir
     
127.     dest_path = target_dir / filename
     
128. 
     
129.     # 检查是否已存在
     
130.     if dest_path.exists():
     
131.         logger.debug(f"文件已存在，跳过: {dest_path}")  # debug 级别，不显示
     
132.         return 0
     
133. 
     
134.     # 确保目录存在
     
135.     ensure_dir(target_dir)
     
136. 
     
137.     # 下载
     
138.     success = download_file(url, dest_path)
     
139.     if success:
     
140.         logger.info(f"成功下载: {filename} 到 {dest_path}")
     
141.         return 1
     
142.     else:
     
143.         logger.error(f"下载失败: {filename}")
     
144.         return -1
     
145. 
     
146. def main():
     
147.     logger.info("===== 开始扫描 strm 文件 =====")
     
148.     ensure_dir(DOWNLOAD_DIR)
     
149. 
     
150.     strm_files = []
     
151.     if RECURSIVE:
     
152.         for root, _, files in os.walk(STRM_DIR):
     
153.             for f in files:
     
154.                 if f.lower().endswith('.strm'):
     
155.                     strm_files.append(os.path.join(root, f))
     
156.     else:
     
157.         for f in os.listdir(STRM_DIR):
     
158.             if f.lower().endswith('.strm'):
     
159.                 strm_files.append(os.path.join(STRM_DIR, f))
     
160. 
     
161.     total = len(strm_files)
     
162.     logger.info(f"共发现 {total} 个 strm 文件")
     
163. 
     
164.     # 统计
     
165.     skipped_exist = 0
     
166.     skipped_keyword = 0
     
167.     downloaded = 0
     
168.     failed = 0
     
169. 
     
170.     for strm_path in strm_files:
     
171.         status = process_strm_file(strm_path)
     
172.         if status == 1:
     
173.             downloaded += 1
     
174.         elif status == 0:
     
175.             skipped_exist += 1
     
176.         elif status == -2:
     
177.             skipped_keyword += 1
     
178.         else:  # -1
     
179.             failed += 1
     
180. 
     
181.     # 最终统计信息
     
182.     logger.info("===== 扫描完成 =====")
     
183.     logger.info(f"总计扫描 strm 文件: {total}")
     
184.     logger.info(f"已存在跳过: {skipped_exist}")
     
185.     logger.info(f"关键词不匹配跳过: {skipped_keyword}")
     
186.     logger.info(f"下载成功: {downloaded}")
     
187.     logger.info(f"下载失败: {failed}")
     
188. 
     
189. if __name__ == "__main__":
     
190.     main()

复制代码

你又出山了

蓝小白 发表于 2026-7-21 13:08
你又出山了