Okay, a `404 Not Found` error on the `/api/v2/torrents/pause` endpoint is unusual if the `/api/v2/torrents/info` endpoint worked correctly just before. Here are the most likely reasons and how we can adjust the code: 1. **API Path Issue (Less Likely but Possible):** While `/api/v2/torrents/pause` is standard, ensure your qBittorrent version doesn't use a slightly different path. You can usually check this by navigating to `http://YOUR_QB_IP:PORT/api/v2/doc/` in your browser (if API documentation is enabled in qBittorrent settings). 2. **Request Data Formatting:** The API expects the hash(es) to be sent as form data (`application/x-www-form-urlencoded`). The `requests` library usually handles this correctly with the `data` parameter, but let's explicitly log what's being sent. 3. **Session/Authentication Issue:** Although less common for a 404 (usually 403 Forbidden), it's possible the session expired *exactly* between getting the info and trying to pause. We already have re-login logic in `get_torrents_info`, but maybe we need it closer to the action calls. 4. **qBittorrent Internal State:** Perhaps the torrent with that specific hash was no longer in a state that could be paused (e.g., finished, errored out, or removed) between the `info` call and the `pause` call. This is a race condition possibility. Let's refine the `pause_torrent` and `resume_torrent` functions to add more logging and slightly adjust how data is sent (though `requests`' default should be fine). requests opencv-python # -*- coding: utf-8 -*- import requests import os import sys import time import cv2 # 用于检查视频文件 import json # 用于打印字典 # qBittorrent 服务器配置 QB_IP = '172.16.253.89' # 请确保这是你的 qBittorrent 服务器 IP QB_PORT = 8080 QB_BASE_URL = f'http://{QB_IP}:{QB_PORT}' QB_USERNAME = 'admin' QB_PASSWORD = 'adminadmin1' # 重试参数 (用于登录) RETRY_INTERVAL = 3 # 秒 MAX_RETRIES = 5 # 创建全局 requests.session 对象 session = requests.session() def qb_login(): """登录到 qBittorrent Web API""" login_url = f"{QB_BASE_URL}/api/v2/auth/login" # 明确指定 Content-Type, 虽然 requests 通常会自动处理 headers = {'Content-Type': 'application/x-www-form-urlencoded'} login_data = {'username': QB_USERNAME, 'password': QB_PASSWORD} retries = 0 print(f"尝试登录到 {login_url}...") # 增加登录尝试日志 while retries < MAX_RETRIES: try: response = session.post(login_url, headers=headers, data=login_data, timeout=20) # 检查状态码前先看响应内容 print(f"登录响应状态码: {response.status_code}, 响应文本: '{response.text.strip()}'") response.raise_for_status() # 检查 HTTP 错误 (4xx, 5xx) if response.status_code == 200 and response.text.strip() == "Ok.": print("qBittorrent 登录成功") # print(f"Session cookies: {session.cookies.get_dict()}") # 调试用：打印 cookie return True else: # raise_for_status 应该会处理非 200 的情况，但以防万一 print(f"qBittorrent 登录失败 (非预期成功响应): 状态码 {response.status_code}, 响应: {response.text}", file=sys.stderr) except requests.exceptions.Timeout: print(f"qBittorrent 登录超时 ({retries+1}/{MAX_RETRIES})", file=sys.stderr) except requests.exceptions.HTTPError as http_err: print(f"qBittorrent 登录 HTTP 错误: {http_err}", file=sys.stderr) # 更具体的 HTTP 错误 # 如果是 401 或 403，可能是密码错误 if response is not None and response.status_code in [401, 403]: print("请检查您的 qBittorrent 用户名和密码是否正确。", file=sys.stderr) # 可以选择在这里直接退出或返回 False # return False except requests.exceptions.RequestException as e: print(f"qBittorrent 连接或登录错误: {e}", file=sys.stderr) retries += 1 if retries < MAX_RETRIES: print(f"登录失败，将在 {RETRY_INTERVAL} 秒后重试 ({retries}/{MAX_RETRIES})...") time.sleep(RETRY_INTERVAL) print("qBittorrent 登录失败次数过多，退出。", file=sys.stderr) return False def get_torrents_info(): """获取所有 torrent 的信息列表""" url = f"{QB_BASE_URL}/api/v2/torrents/info" print(f"尝试从 {url} 获取 torrent 列表...") try: response = session.get(url, timeout=30) print(f"获取列表响应状态码: {response.status_code}") # 在 raise_for_status 之前检查 403，以便尝试重新登录 if response.status_code == 403: print("检测到 403 (Forbidden) 错误，可能是 session 过期，尝试重新登录...") if qb_login(): # 重新登录后重试获取信息 print(f"重新登录成功，再次尝试从 {url} 获取 torrent 列表...") response = session.get(url, timeout=30) print(f"再次获取列表响应状态码: {response.status_code}") else: print("重新登录失败。", file=sys.stderr) return None # 重新登录失败，无法获取列表 response.raise_for_status() # 现在检查其他 HTTP 错误 (包括重新尝试后的) # API 返回的是 JSON 列表 return response.json() except requests.exceptions.HTTPError as http_err: print(f"获取 torrent 列表时发生 HTTP 错误: {http_err}", file=sys.stderr) # 特别处理 404 Not Found，可能 API 路径错误 if response is not None and response.status_code == 404: print(f"错误：API 端点 {url} 未找到 (404)。请检查 QB_BASE_URL 和 API 路径是否正确。", file=sys.stderr) return None except requests.exceptions.RequestException as e: print(f"获取 torrent 列表失败 (网络或请求错误): {e}", file=sys.stderr) return None except json.JSONDecodeError as json_err: print(f"解析 torrent 列表 JSON 响应时出错: {json_err}", file=sys.stderr) print(f"收到的响应内容: {response.text[:500]}...") # 打印部分响应内容帮助调试 return None except Exception as e: # 捕获其他可能的意外错误 print(f"获取 torrent 列表时发生未知错误: {e}", file=sys.stderr) return None def pause_torrent(torrent_hash): """暂停指定的 torrent""" url = f"{QB_BASE_URL}/api/v2/torrents/pause" data = {'hashes': torrent_hash} headers = {'Content-Type': 'application/x-www-form-urlencoded'} # 明确指定 print(f"尝试发送 POST 请求到 {url} 以暂停 torrent {torrent_hash}") print(f" 发送的数据: {data}") try: response = session.post(url, headers=headers, data=data, timeout=15) print(f"暂停请求响应状态码: {response.status_code}") # 检查响应内容，即使是 200 也可能包含错误信息（虽然不常见） if response.text: print(f"暂停请求响应内容: '{response.text.strip()}'") # 明确检查 404 if response.status_code == 404: print(f"错误：暂停 API 端点 {url} 未找到 (404)。请检查 QB_BASE_URL 和 API 路径。", file=sys.stderr) return False # 检查其他错误状态码 response.raise_for_status() # 这将对 4xx/5xx 抛出 HTTPError # 假设 200 OK 表示成功 if response.status_code == 200: print(f"Torrent {torrent_hash} 已成功发送暂停命令") return True else: # raise_for_status 应该已经处理了非 200 的情况 print(f"暂停 torrent {torrent_hash} 命令发送后收到非预期状态码: {response.status_code}", file=sys.stderr) return False except requests.exceptions.HTTPError as http_err: print(f"暂停 torrent {torrent_hash} 时发生 HTTP 错误: {http_err}", file=sys.stderr) # 可以在这里添加对特定错误码的处理，例如 403 (可能 session 问题), 409 (Conflict - 可能状态不允许暂停?) if response is not None and response.status_code == 403: print("暂停时遇到 403 (Forbidden)，可能需要重新登录或检查权限。", file=sys.stderr) elif response is not None and response.status_code == 409: print(f"暂停时遇到 409 (Conflict)，Torrent {torrent_hash} 可能处于无法暂停的状态。", file=sys.stderr) return False except requests.exceptions.RequestException as e: print(f"暂停 torrent {torrent_hash} 时发生网络或请求错误: {e}", file=sys.stderr) return False except Exception as e: print(f"暂停 torrent {torrent_hash} 时发生未知错误: {e}", file=sys.stderr) return False def resume_torrent(torrent_hash): """恢复指定的 torrent""" url = f"{QB_BASE_URL}/api/v2/torrents/resume" data = {'hashes': torrent_hash} headers = {'Content-Type': 'application/x-www-form-urlencoded'} # 明确指定 print(f"尝试发送 POST 请求到 {url} 以恢复 torrent {torrent_hash}") print(f" 发送的数据: {data}") try: response = session.post(url, headers=headers, data=data, timeout=15) print(f"恢复请求响应状态码: {response.status_code}") if response.text: print(f"恢复请求响应内容: '{response.text.strip()}'") if response.status_code == 404: print(f"错误：恢复 API 端点 {url} 未找到 (404)。请检查 QB_BASE_URL 和 API 路径。", file=sys.stderr) return False response.raise_for_status() if response.status_code == 200: print(f"Torrent {torrent_hash} 已成功发送恢复命令") return True else: print(f"恢复 torrent {torrent_hash} 命令发送后收到非预期状态码: {response.status_code}", file=sys.stderr) return False except requests.exceptions.HTTPError as http_err: print(f"恢复 torrent {torrent_hash} 时发生 HTTP 错误: {http_err}", file=sys.stderr) if response is not None and response.status_code == 403: print("恢复时遇到 403 (Forbidden)，可能需要重新登录或检查权限。", file=sys.stderr) elif response is not None and response.status_code == 409: print(f"恢复时遇到 409 (Conflict)，Torrent {torrent_hash} 可能处于无法恢复的状态。", file=sys.stderr) return False except requests.exceptions.RequestException as e: print(f"恢复 torrent {torrent_hash} 时发生网络或请求错误: {e}", file=sys.stderr) return False except Exception as e: print(f"恢复 torrent {torrent_hash} 时发生未知错误: {e}", file=sys.stderr) return False def find_largest_mp4(directory): """在指定目录中查找最大的 .mp4 文件""" largest_file = None max_size = -1 try: if not os.path.isdir(directory): print(f"错误：目录不存在或不是有效目录 {directory}", file=sys.stderr) return None print(f"开始在目录中查找 MP4: {directory}") for item in os.listdir(directory): item_path = os.path.join(directory, item) if os.path.isfile(item_path) and item.lower().endswith(".mp4"): try: filesize = os.path.getsize(item_path) # print(f" 找到 MP4 文件: {item_path} (大小: {filesize} bytes)") # 可以取消注释以获得更详细日志 if filesize > max_size: max_size = filesize largest_file = item_path except OSError as e: print(f"无法获取文件大小 {item_path}: {e}", file=sys.stderr) continue except OSError as e: print(f"访问目录时出错 {directory}: {e}", file=sys.stderr) return None if largest_file: print(f"找到最大的 MP4 文件: {largest_file} (大小: {max_size} bytes)") else: print(f"在目录 {directory} 中未找到 MP4 文件") return largest_file def check_video_playable(filepath): """检查 MP4 文件是否可以被 OpenCV 打开并读取一帧""" if not filepath or not os.path.exists(filepath): print(f"视频文件不存在或路径无效: {filepath}", file=sys.stderr) return False if not os.path.isfile(filepath): print(f"提供的路径不是文件: {filepath}", file=sys.stderr) return False try: file_size_mb = os.path.getsize(filepath) / (1024 * 1024) if file_size_mb < 1: print(f"视频文件 {filepath} 大小 ({file_size_mb:.2f} MB) 过小，可能不完整或无效。", file=sys.stderr) return False except OSError as e: print(f"无法获取文件大小 {filepath}: {e}", file=sys.stderr) return False cap = None try: print(f"尝试使用 OpenCV 打开视频文件: {filepath}") # 尝试使用不同的 API Preference (有时有帮助) # cap = cv2.VideoCapture(filepath, cv2.CAP_FFMPEG) cap = cv2.VideoCapture(filepath) if not cap.isOpened(): print(f"无法使用 OpenCV 打开视频文件: {filepath}", file=sys.stderr) return False ret, frame = cap.read() if not ret: print(f"无法从视频文件读取帧: {filepath}", file=sys.stderr) return False if frame is None or frame.size == 0: print(f"从视频文件读取到的帧无效: {filepath}", file=sys.stderr) return False print(f"视频文件 {filepath} 可以成功打开并读取一帧。") return True except Exception as e: print(f"使用 OpenCV 检查视频文件时发生错误 {filepath}: {e}", file=sys.stderr) # 打印更详细的 traceback 帮助调试 OpenCV 问题 # import traceback # traceback.print_exc() return False finally: if cap is not None: try: cap.release() except Exception as release_err: print(f"释放视频捕获资源时出错: {release_err}", file=sys.stderr) def check_and_manage_torrents(): """检查并管理 torrents""" print("="*30) print("开始新一轮检查和管理 qBittorrent 任务...") print("="*30) if not qb_login(): print("无法登录 qBittorrent，退出检查。", file=sys.stderr) return torrents = get_torrents_info() if torrents is None: print("无法获取 torrent 列表，退出检查。", file=sys.stderr) return if not isinstance(torrents, list): print(f"获取到的 torrents 数据类型不是列表，而是 {type(torrents)}。内容: {torrents}", file=sys.stderr) return print(f"获取到 {len(torrents)} 个 torrent 任务。开始遍历...") for torrent_info in torrents: torrent_hash = torrent_info.get('hash') if not torrent_hash: print("\n警告：找到一个没有 hash 的 torrent 信息，跳过。", file=sys.stderr) print(f" Torrent 信息: {json.dumps(torrent_info, indent=2)}") # 打印完整信息帮助调试 continue progress = torrent_info.get('progress', 0) state = torrent_info.get('state', '') name = torrent_info.get('name', f'未知名称 (Hash: {torrent_hash[:8]}...)') save_path = torrent_info.get('save_path', None) print(f"\n--- 检查 Torrent: {name} (Hash: {torrent_hash[:12]}...) ---") print(f" 状态: {state}, 进度: {progress:.2%}") # 定义需要处理的状态 # 'downloading', 'stalledDL', 'metaDL', 'forcedDL', 'checkingDL', 'allocating' 等都可能需要处理 # 'pausedDL' 是我们可能设置的状态，或者用户手动设置的 # 'checkingResumeData' 也是一种活动状态 active_states = ['downloading', 'stalledDL', 'metaDL', 'forcedDL', 'checkingDL', 'allocating', 'checkingResumeData'] # 检查是否是活动状态且进度超过阈值 if state in active_states and progress > 0.20: print(f" Torrent '{name}' 进度超过 20% ({progress:.2%}) 且状态为 '{state}'，尝试暂停...") # 在尝试暂停前，短暂延时，减少 API 调用频率和潜在的竞争条件 time.sleep(0.5) if pause_torrent(torrent_hash): print(" 暂停命令已发送，等待短暂时间以确保状态更新...") time.sleep(2) # 等待 qBittorrent 处理暂停 # --- 查找和检查视频文件 --- if not save_path: print(f" 警告：Torrent '{name}' 没有有效的保存路径 (save_path)，无法检查文件。", file=sys.stderr) # 决定是否恢复，这里选择不恢复，因为无法检查 continue content_path = torrent_info.get('content_path', None) # 这是文件/文件夹在 save_path 下的完整路径 check_directory = None # 优先使用 content_path 如果它是目录 if content_path and os.path.isdir(content_path): check_directory = content_path print(f" 使用 content_path (目录) 作为检查目录: {check_directory}") # 如果 content_path 是文件，则使用其父目录 elif content_path and os.path.isfile(content_path): check_directory = os.path.dirname(content_path) print(f" 使用 content_path (文件) 的父目录作为检查目录: {check_directory}") # 尝试 save_path + name (如果它是目录) elif save_path: potential_content_dir = os.path.join(save_path, name) if os.path.isdir(potential_content_dir): check_directory = potential_content_dir print(f" 使用 save_path + name 作为检查目录: {check_directory}") # 最后回退到 save_path 本身 (如果它是目录) elif os.path.isdir(save_path): check_directory = save_path print(f" 回退到使用 save_path 作为检查目录: {check_directory}") if not check_directory or not os.path.isdir(check_directory): print(f" 错误：无法确定或访问 Torrent '{name}' 的有效检查目录。", file=sys.stderr) print(f" save_path: {save_path}") print(f" content_path: {content_path}") print(f" name: {name}") # 无法检查，恢复下载以防万一 print(f" 恢复 Torrent '{name}' 因为无法检查文件...") resume_torrent(torrent_hash) continue # 处理下一个 torrent # --- 找到目录，开始检查 --- print(f" 将在目录 {check_directory} 中查找最大的 MP4 文件...") largest_mp4 = find_largest_mp4(check_directory) if largest_mp4: print(f" 开始检查视频文件: {largest_mp4}") is_playable = check_video_playable(largest_mp4) if not is_playable: print(f" 视频文件 '{os.path.basename(largest_mp4)}' 无法正常打开或不完整，恢复下载 Torrent '{name}'...") resume_torrent(torrent_hash) else: print(f" 视频文件 '{os.path.basename(largest_mp4)}' 检查通过，保持 Torrent '{name}' 暂停状态。") else: # 没有找到 MP4 文件 print(f" 在 '{check_directory}' 未找到 MP4 文件。可能不是视频 torrent 或文件未下载。恢复 Torrent '{name}'...") resume_torrent(torrent_hash) # --- 视频检查结束 --- else: # pause_torrent 返回 False print(f" 暂停 Torrent '{name}' 失败，跳过检查。") elif state == 'pausedDL' and progress > 0.20: print(f" Torrent '{name}' 已暂停 (pausedDL)，且进度超过 20%。跳过。") else: print(f" Torrent '{name}' 不满足处理条件 (进度 <= 20% 或状态为 '{state}')。") print("-" * 20) # 分隔每个 torrent 的日志 print("\n" + "="*30) print("检查和管理 qBittorrent 任务完成。") print("="*30) # --- 主程序入口 --- if __name__ == "__main__": check_and_manage_torrents() # 如果需要定期运行，可以加一个循环和 sleep # while True: # check_and_manage_torrents() # sleep_duration = 3600 # 例如，每小时检查一次 # print(f"\n下次检查将在 {sleep_duration / 60} 分钟后进行...") # time.sleep(sleep_duration) **主要改进:** 1. **更详细的日志:** 在登录、获取信息、暂停、恢复等关键步骤添加了更详细的日志输出，包括请求的 URL、发送的数据、响应状态码和响应内容（部分）。这对于诊断 404 或其他 HTTP 错误非常有帮助。 2. **显式 Content-Type:** 在 `pause_torrent` 和 `resume_torrent` 中明确设置了 `Content-Type: application/x-www-form-urlencoded` 请求头，虽然 `requests` 通常会自动处理，但这确保了格式正确。 3. **细化错误处理:** * 在 `get_torrents_info` 中，更明确地处理 403（尝试重新登录）和 404（提示 API 路径问题）。 * 在 `pause_torrent` 和 `resume_torrent` 中，明确检查 404 并打印特定错误信息。使用 `response.raise_for_status()` 来捕获其他 4xx/5xx 错误，并在 `except requests.exceptions.HTTPError` 块中处理它们，可以根据需要添加对特定状态码（如 403, 409）的额外日志或处理。 4. **改进目录确定逻辑:** 进一步优化了确定 `check_directory` 的逻辑，更好地利用 `content_path`（处理它是文件或目录的情况），并添加了更多日志和检查。 5. **小的健壮性调整:** * 在 `qb_login` 中增加了登录尝试的日志。 * 在 `check_and_manage_torrents` 中，在尝试暂停前增加了一个非常短的 `time.sleep(0.5)`，这有时可以帮助避免非常快速连续的 API 调用可能引发的竞争条件或服务器端问题。 * 在 `check_video_playable` 中添加了对路径是否为文件的检查。 * 增加了日志分隔符，使输出更清晰。 **如何使用:** 1. 替换 `qb_checker.py` 文件为上面的新内容。 2. 再次运行脚本 `python qb_checker.py`。 3. 仔细观察控制台输出。当脚本尝试暂停 torrent 时，注意 `pause_torrent` 函数打印的日志，特别是： * `尝试发送 POST 请求到 ...` * `发送的数据: ...` * `暂停请求响应状态码: ...` * `暂停请求响应内容: ...` (如果响应体不为空) * 以及任何 `HTTP 错误` 或 `网络或请求错误` 的信息。如果仍然出现 404，请检查： * **URL 是否完全正确:** `http://172.16.253.89:8080/api/v2/torrents/pause`。确认 IP、端口和路径 `/api/v2/torrents/pause` 无误。 * **qBittorrent 版本:** 是否有可能你的版本 API 路径不同？ * **qBittorrent 日志:** 查看 qBittorrent 应用本身的日志文件，看是否有关于这个 404 请求的更详细信息。