design design batch
This commit is contained in:
@@ -445,7 +445,7 @@ async def design(file: UploadFile = File(...),
|
|||||||
|
|
||||||
async def save_request_file(contents, file_name):
|
async def save_request_file(contents, file_name):
|
||||||
# 创建保存文件的目录(如果不存在)
|
# 创建保存文件的目录(如果不存在)
|
||||||
save_dir = os.path.join(os.getcwd(), "design_batch", "request_data")
|
save_dir = os.path.join(os.getcwd(), "service/design_batch", "request_data")
|
||||||
if not os.path.exists(save_dir):
|
if not os.path.exists(save_dir):
|
||||||
os.makedirs(save_dir)
|
os.makedirs(save_dir)
|
||||||
# 处理文件
|
# 处理文件
|
||||||
|
|||||||
@@ -1,13 +1,19 @@
|
|||||||
import json
|
import json
|
||||||
import logging
|
import logging
|
||||||
|
import os
|
||||||
|
|
||||||
logger = logging.getLogger()
|
logger = logging.getLogger()
|
||||||
|
|
||||||
|
|
||||||
def oss_upload_json(oss_client, json_data, object_name):
|
def oss_upload_json(oss_client, json_data, object_name):
|
||||||
try:
|
try:
|
||||||
with open(f"app/service/design_batch/response_json/{object_name}", 'w') as file:
|
save_dir = os.path.join(os.getcwd(), "service/design_batch", "response_data")
|
||||||
|
if not os.path.exists(save_dir):
|
||||||
|
os.makedirs(save_dir)
|
||||||
|
# 处理文件
|
||||||
|
file_path = os.path.join(save_dir, object_name)
|
||||||
|
with open(file_path, 'w') as file:
|
||||||
json.dump(json_data, file, indent=4)
|
json.dump(json_data, file, indent=4)
|
||||||
oss_client.fput_object("test", object_name, f"app/service/design_batch/response_json/{object_name}")
|
oss_client.fput_object("test", object_name, file_path)
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
logger.warning(str(e))
|
logger.warning(str(e))
|
||||||
|
|||||||
Reference in New Issue
Block a user