使用aiohttp异步调用API+request上传文件中文文档名乱码解决方案

昵称是湖海

有时候在调用需要用异步调用API接口。在python中有很多框架，比如 asyncio， Celery，Quart 等。这里我选择了 asyncio。Python 3.5以上版本内置了asyncio库，可以用来编写单线程的并发代码。可以使用此库与aiohttp结合来发送异步HTTP请求。
Python调用案例

GET

1. import asyncio
2. import aiohttp
4. async def fetch(session, url):
5.     async with session.get(url) as response:
6.         return await response.text()
8. async def main():
9.     # 指定要请求的URL
10.     url = "http://example.com"
11.    
12.     # 创建一个异步的HTTP会话
13.     async with aiohttp.ClientSession() as session:
14.         html = await fetch(session, url)  # 发送请求并获取响应
15.         print(html)  # 打印响应内容
17. # 运行异步主函数
18. asyncio.run(main())

复制代码

POST

参数为JSON

1. import asyncio
2. import aiohttp
4. async def fetch(session, url, data):
5.     # 使用session.post发送POST请求，data是POST请求的数据
6.     async with session.post(url, data=data) as response:
7.         return await response.text()  # 返回响应的文本内容
9. async def main():
10.     url = "http://example.com"  # 指定URL
11.     data = {'key': 'value'}  # 准备发送的数据
13.     async with aiohttp.ClientSession() as session:
14.         html = await fetch(session, url, data)  # 发送POST请求并获取响应
15.         print(html)  # 打印响应内容
17. # 运行异步主函数
18. asyncio.run(main())

复制代码

需要同时上传文件和JSON参数

1. import asyncio
2. import aiohttp
3. from aiohttp import FormData
5. async def fetch(session, url, data):
6.     async with session.post(url, data=data) as response:
7.         return await response.text()
9. async def main():
10.     url = "http://example.com/upload"  # 模拟的文件上传URL
12.     # 准备文件字典
13.     files = {
14.         'file1': open('example1.txt', 'rb'),
15.         'file2': open('example2.txt', 'rb')
16.     }
18.     # 准备普通表单数据
19.     form_data = {
20.         'username': 'user1',
21.         'password': 'pass123'
22.     }
24.     data = FormData()
25.     # 添加普通表单数据
26.     for key, value in form_data.items():
27.         data.add_field(key, value)
28.    
29.     # 添加文件
30.     for file_name, file_obj in files.items():
31.         data.add_field(file_name,
32.                        file_obj,
33.                        filename=file_name,
34.                        content_type='text/plain'        # 这里可以不填或者根据自己上传的文件格式修改
35.                       )
37.     async with aiohttp.ClientSession() as session:
38.         html = await fetch(session, url, data)  # 发送文件和其他数据
39.         print(html)
41.     # 确保所有文件在发送后都已关闭
42.     for file in files.values():
43.         file.close()
45. # 运行异步主函数
46. asyncio.run(main())

复制代码

中文文档名报错

在上传文档路径名文件路径包含了中文字符时，使用aiohttp传递参数会将文件名变成乱码，这通常是因为路径中的非ASCII字符被编码成了URL编码或者类似的格式。
在request端无法进行修改，我们可以在被调用的api中需要用到filename处增加这一行来进行更改：

1. from urllib.parse import unquote
3. file.filename = unquote(file.filename)

复制代码

来源:https://www.cnblogs.com/tungsten106/p/async_request_filename_error.html
免责声明：由于采集信息均来自互联网，如果侵犯了您的权益，请联系我们【E-Mail:cb@itdo.tech】 我们会及时删除侵权内容，谢谢合作！