|
@@ -8,7 +8,7 @@ from stream import StreamCapture
|
|
|
from infer import DoorInference
|
|
|
from logger import logger
|
|
|
|
|
|
-async def upload_image(session, url, payload, files):
|
|
|
+async def upload_image(session, url, payload, filename1, content1, filename2, content2):
|
|
|
try:
|
|
|
form_data = aiohttp.FormData()
|
|
|
# 添加普通表单数据
|
|
@@ -16,10 +16,8 @@ async def upload_image(session, url, payload, files):
|
|
|
form_data.add_field(key, value)
|
|
|
|
|
|
# 添加文件数据
|
|
|
- for key, (filename, content, content_type) in files:
|
|
|
- content_io = io.BytesIO(content)
|
|
|
- content_io.seek(0)
|
|
|
- form_data.add_field(key, content_io, filename=filename, content_type=content_type)
|
|
|
+ form_data.add_field('file', content1, filename=filename1, content_type='image/jpeg')
|
|
|
+ form_data.add_field('oldFile', content2, filename=filename2, content_type='image/jpeg')
|
|
|
|
|
|
# 发起 POST 请求
|
|
|
async with session.post(url, data=form_data) as response:
|
|
@@ -77,13 +75,8 @@ async def process_stream():
|
|
|
'videoUrl': stream.stream_url
|
|
|
}
|
|
|
|
|
|
- files = [
|
|
|
- ('file', (filename, content, 'image/jpeg')),
|
|
|
- ('oldFile', (filenameori, contentori, 'image/jpeg'))
|
|
|
- ]
|
|
|
-
|
|
|
# 使用协程上传图像
|
|
|
- await upload_image(session, 'http://172.19.152.231/open/api/operate/upload', payload, files)
|
|
|
+ await upload_image(session, 'http://172.19.152.231/open/api/operate/upload', payload, filename, content, filenameori, contentori)
|
|
|
except Exception as error:
|
|
|
logger.error(f'Error: {str(error)}')
|
|
|
|