### 使用 Python 的 requests 库结合 MultipartEncoder 实现文件分块流式上传 以下是一个完整的实现方案，确保文件在上传过程中被正确关闭，并且使用了 `with` 语句来管理文件资源。 ```python import os import requests from requests_toolbelt.multipart.encoder import MultipartEncoder def upload_file_in_chunks(file_path, url, chunk_size=8192): try: # 使用 with 语句打开文件以确保文件在任何情况下都被正确关闭 with open(file_path, 'rb') as file: # 创建一个生成器函数，用于分块读取文件 def generate_chunks(): while True: data = file.read(chunk_size) if not data: break yield (os.path.basename(file_path), data, 'application/octet-stream') # 构建 MultipartEncoder 对象 multipart_encoder = MultipartEncoder( fields={ 'file': generate_chunks(), # 文件字段 'packageId': 'example_package_id', # 示例字段 'name': 'example_name', # 示例字段 'message': 'example_message', # 示例字段 } ) # 设置请求头 headers = { 'Content-Type': multipart_encoder.content_type, } # 发送 POST 请求并启用流式传输 response = requests.post(url, data=multipart_encoder, headers=headers) 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) ``` ### 代码说明 - **文件打开与关闭**： - 使用 `with open()` 语句打开文件，这样可以确保在代码块结束时自动关闭文件[^3]。 - 在 `finally` 块中打印确认信息，表明文件已被关闭。 - **分块读取文件**： - 定义了一个生成器函数 `generate_chunks()`，它每次从文件中读取固定大小的数据块（由 `chunk_size` 参数控制）[^2]。 - 如果文件较大，这种方法可以显著减少内存占用。 - **MultipartEncoder**： - 使用 `requests_toolbelt.multipart.encoder.MultipartEncoder` 来构建多部分表单数据[^4]。 - 将生成器函数 `generate_chunks()` 作为文件字段值传递给 `MultipartEncoder`，以实现流式上传[^1]。 - **异常处理**： - 使用 `try-except` 结构捕获可能的异常，例如文件找不到、编码错误或网络请求失败等[^3]。 - **状态检查**： - 调用 `response.raise_for_status()` 检查 HTTP 响应的状态码，确保请求成功[^4]。 ### 注意事项 - `chunk_size` 参数决定了每次读取和发送的数据量。可以根据实际需求调整该值，通常建议设置为 KB 或 MB 级别。 - 目标服务器需要支持分块上传功能，否则可能会导致请求失败。 - 在构建 `MultipartEncoder` 时，确保字段名称和服务器端要求一致[^4]。 --- ###