Python - 第三方HTTP库Requests使用详解4（文件上传）

作者：hangge | 2022-06-29 14:56

五、文件上传（Form 表单方式）

1，单文件上传

（1）下面是最简单的文件上传代码，运行后将 logo.png 这个文件上传到服务器：

import requests

files = {'file1': open('logo.png', 'rb')}
response = requests.post('http://www.hangge.com/upload.php', files=files)
print(response.text)

（2）我们也可以显式地设置文件名，文件类型和请求头：

import requests

files = {'file1': ('hangge.png', open('logo.png', 'rb'), 'image/png', {'Expires': '0'})}
response = requests.post('http://www.hangge.com/upload.php', files=files)
print(response.text)

（3）服务端代码（upload.php）

<? 
move_uploaded_file($_FILES["file1"]["tmp_name"],
    $_SERVER["DOCUMENT_ROOT"]."/uploadFiles/" . $_FILES["file1"]["name"]);
?>

2，多文件上传

（1）有时我们需要在一个请求中同时发送多个文件，同样使用 files 参数传入一个数组即可：

import requests

files = [
        ('file1', ('1.png', open('logo.png', 'rb'), 'image/png')),
        ('file2', ('2.png', open('logo.png', 'rb'), 'image/png'))
]
response = requests.post('http://www.hangge.com/upload.php', files=files)
print(response.text)

（2）服务端代码（upload.php）

<? 
move_uploaded_file($_FILES["file1"]["tmp_name"],
    $_SERVER["DOCUMENT_ROOT"]."/uploadFiles/" . $_FILES["file1"]["name"]);
 
move_uploaded_file($_FILES["file2"]["tmp_name"],
    $_SERVER["DOCUMENT_ROOT"]."/uploadFiles/" . $_FILES["file2"]["name"]);
?>

3，上传时附带其它参数

（1）如果我们需要在上传文件的同时传递一些其它参数，也是可以的：

import requests

data = {
    "name": "hangge.com",
    "age": 100
}
files = [
        ('file1', ('1.png', open('logo.png', 'rb'), 'image/png')),
        ('file2', ('2.png', open('logo.png', 'rb'), 'image/png'))
]
response = requests.post('http://www.hangge.com/upload.php', data=data, files=files)
print(response.text)

（2）服务端代码（upload.php）

<? 
$value1 = $_POST["name"];
$value2 = $_POST["age"];

move_uploaded_file($_FILES["file1"]["tmp_name"],
    $_SERVER["DOCUMENT_ROOT"]."/uploadFiles/" . $_FILES["file1"]["name"]);

move_uploaded_file($_FILES["file2"]["tmp_name"],
    $_SERVER["DOCUMENT_ROOT"]."/uploadFiles/" . $_FILES["file2"]["name"]);
?>

附：流式上传文件

1，requests-toolbelt 扩展库

（1）有时我们需要上传一个非常大的文件（比如 1G 左右），如果像上面的方式直接使用 Requests 提交，可能会造成内存不足而崩溃。

（2）所以发送大文件时还是建议将请求做成数据流。不过默认下 Requests 不支持流式上传，但有个第三方包 requests-toolbelt 是支持的（本质还是 multipart/form-data 上传）

（3）在使用 requests-toolbelt 之前，我们首先通过 pip 进行安装：

pip install requests-toolbelt

2，使用流式上传文件

下面样例我们使用 requests-toolbelt 来实现文件的流式上传：

不同于 requests 全部读到内存中上传，requests-toolbelt 是边读边上传。
其本质还是 multipart/form-data 提交数据，所以服务端代码不需要变化。

import requests
from requests_toolbelt import MultipartEncoder

m = MultipartEncoder(
    fields={'name': 'hangge.com', "age": '100',
            'file1': ('1.png', open('logo.png', 'rb'), 'image/png'),
            'file2': ('2.png', open('logo.png', 'rb'), 'image/png')}
    )
r = requests.post('http://www.hangge.com/upload.php', data=m,
                  headers={'Content-Type': m.content_type})
print(r.text)

3，监听上传进度

（1）requests-toolbelt 还提供了个监视器（MultipartEncoderMonitor），该监视器接受一个回调函数，我们可以在回调中实时跟踪进度。

import requests
from requests_toolbelt import MultipartEncoder, MultipartEncoderMonitor


def my_callback(monitor):
    progress = (monitor.bytes_read / monitor.len) * 100
    print("\r 文件上传进度：%d%%(%d/%d)"
          % (progress, monitor.bytes_read, monitor.len), end=" ")


e = MultipartEncoder(
    fields={'name': 'hangge.com', "age": '100',
            'file1': ('1.png', open('logo.png', 'rb'), 'image/png'),
            'file2': ('2.png', open('logo.png', 'rb'), 'image/png')}
    )


m = MultipartEncoderMonitor(e, my_callback)

r = requests.post('http://www.hangge.com/upload.php', data=m,
                  headers={'Content-Type': m.content_type})
print(r.text)

（2）运行效果如下，可以看到提交过程中会实时显示进度：

Python / AI