### 文件分块流式上传的实现 使用 Python 的 `requests` 库可以实现文件的分块流式上传。通过设置 `stream=True` 参数，可以在请求中逐步发送文件内容，而不是一次性将整个文件加载到内存中。此外，在 `finally` 块中关闭文件可以确保无论是否发生异常，文件句柄都会被正确释放。 以下是实现文件分块流式上传的代码示例： ```python import requests def upload_file_in_chunks(file_path, url, chunk_size=1024): try: # 打开文件以二进制模式读取 with open(file_path, 'rb') as file: # 创建一个生成器函数，用于分块读取文件 def generate_chunks(): while True: data = file.read(chunk_size) if not data: break yield data # 发送 POST 请求并启用流式传输 response = requests.post(url, data=generate_chunks(), stream=True) response.raise_for_status() # 检查 HTTP 响应状态码 print("文件上传成功！") except FileNotFoundError: print("错误：指定的文件不存在。") except LookupError: print("错误：指定了未知的编码。") except UnicodeDecodeError: print("错误：无法按指定方式解码文件内容。") except requests.exceptions.RequestException as e: print(f"HTTP 请求错误：{e}") finally: # 确保文件在任何情况下都被正确关闭 print("文件已关闭。") # 示例调用 file_path = 'example.txt' # 替换为实际文件路径 url = 'http://httpbin.org/post' # 替换为目标服务器 URL upload_file_in_chunks(file_path, url, chunk_size=8192) ``` ### 代码说明 1. **文件打开与关闭**： - 使用 `with open()` 语句打开文件，这样可以确保在代码块结束时自动关闭文件[^3]。 - 在 `finally` 块中打印确认信息，表明文件已被关闭。 2. **分块读取文件**： - 定义了一个生成器函数 `generate_chunks()`，它每次从文件中读取固定大小的数据块（由 `chunk_size` 参数控制）[^2]。 - 如果文件较大，这种方法可以显著减少内存占用。 3. **启用流式传输**： - 在 `requests.post()` 方法中设置 `stream=True`，以支持流式传输[^2]。 4. **异常处理**： - 使用 `try-except` 结构捕获可能的异常，例如文件找不到、编码错误或网络请求失败等。 5. **状态检查**： - 调用 `response.raise_for_status()` 检查 HTTP 响应的状态码，确保请求成功[^4]。 ### 注意事项 - `chunk_size` 参数决定了每次读取和发送的数据量。可以根据实际需求调整该值，通常建议设置为 KB 或 MB 级别。 - 目标服务器需要支持分块上传功能，否则可能会导致请求失败。 --- ###