|
@@ -8,22 +8,19 @@ from infer import DoorInference
|
|
|
from logger import logger
|
|
|
|
|
|
async def upload_image(session, url, payload, files):
|
|
|
- try:
|
|
|
- form_data = aiohttp.FormData()
|
|
|
- # 添加普通表单数据
|
|
|
- for key, value in payload.items():
|
|
|
- form_data.add_field(key, value)
|
|
|
+ form_data = aiohttp.FormData()
|
|
|
+ # 添加普通表单数据
|
|
|
+ for key, value in payload.items():
|
|
|
+ form_data.add_field(key, value)
|
|
|
|
|
|
- # 添加文件数据
|
|
|
- for key, (filename, content, content_type) in files:
|
|
|
- form_data.add_field(key, content, filename=filename, content_type=content_type)
|
|
|
-
|
|
|
- # 发起 POST 请求
|
|
|
- async with session.post(url, data=form_data) as response:
|
|
|
- result = await response.text()
|
|
|
- logger.info(result)
|
|
|
- except Exception as error:
|
|
|
- logger.error(f'Error: {str(error)}')
|
|
|
+ # 添加文件数据
|
|
|
+ for key, (filename, content, content_type) in files:
|
|
|
+ form_data.add_field(key, content, filename=filename, content_type=content_type)
|
|
|
+
|
|
|
+ # 发起 POST 请求
|
|
|
+ async with session.post(url, data=form_data) as response:
|
|
|
+ result = await response.text()
|
|
|
+ logger.info(result)
|
|
|
|
|
|
async def process_stream():
|
|
|
logger.info("====== Start Server =======")
|