Spaces:
Sleeping
Sleeping
Commit
•
e472c61
1
Parent(s):
f4e9f9b
Update api.py
Browse files
api.py
CHANGED
@@ -101,11 +101,23 @@ async def execute_py_file(file_name: str,background_tasks: BackgroundTasks):
|
|
101 |
|
102 |
#收到图片后为了后台任务的顺序,单独设定一个函数依次将自定义执行顺序加入队列 ,有默认参数的写后面-并且和bili合并,不然还要等output.mp4生成后才能发起提交请求
|
103 |
@app.get("/execute_all_task")
|
104 |
-
async def execute_all_task(background_tasks: BackgroundTasks,file_list: list = ["1removeMask", "2magiDialogCut", "3mergeDialogToVideo"
|
105 |
-
bili_meta_data:dict = None,
|
|
|
|
|
106 |
):
|
107 |
for file_name in file_list:
|
108 |
background_tasks.add_task(file_executer, file_name)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
109 |
return {"message": "Tasks added to the queue"}
|
110 |
|
111 |
|
@@ -145,12 +157,3 @@ async def upload_video():
|
|
145 |
|
146 |
await uploader.start()
|
147 |
|
148 |
-
@app.post("/upload_video")
|
149 |
-
async def run_upload_video(meta: dict = Body(...),cover_image: UploadFile = File(...), save_path: str = "/cover"):
|
150 |
-
cover_img = cover_image.file.read()
|
151 |
-
cover_img_data = Image.open(io.BytesIO(img)).convert("L").convert("RGB")
|
152 |
-
path_to_image = os.path.join(save_path, f"cover.jpg")
|
153 |
-
cover_img_data.save(path_to_image)
|
154 |
-
#video数据从meta用户请求获取,至于
|
155 |
-
await upload_video(meta)
|
156 |
-
return {"message": "Video upload completed"}
|
|
|
101 |
|
102 |
#收到图片后为了后台任务的顺序,单独设定一个函数依次将自定义执行顺序加入队列 ,有默认参数的写后面-并且和bili合并,不然还要等output.mp4生成后才能发起提交请求
|
103 |
@app.get("/execute_all_task")
|
104 |
+
async def execute_all_task(background_tasks: BackgroundTasks,file_list: list = ["1removeMask", "2magiDialogCut", "3mergeDialogToVideo"],
|
105 |
+
bili_meta_data:dict = None,cover_image: UploadFile = File(...),mp4_out_file:str='mp4_out/output.mp4',
|
106 |
+
allow_submit:"是否将结果允许上传"=False,cover_path:str ='/cover'
|
107 |
+
|
108 |
):
|
109 |
for file_name in file_list:
|
110 |
background_tasks.add_task(file_executer, file_name)
|
111 |
+
if allow_submit:
|
112 |
+
#如果请求中设置允许上传output.mp4
|
113 |
+
cover_img = cover_image.file.read()
|
114 |
+
cover_img_data = Image.open(io.BytesIO(img)).convert("L").convert("RGB")
|
115 |
+
path_to_image = os.path.join(cover_path, f"cover.jpg")
|
116 |
+
cover_img_data.save(path_to_image)
|
117 |
+
#video数据从meta用户请求获取,至于
|
118 |
+
background_tasks.add_task(upload_video, bili_meta_data)
|
119 |
+
return {"message": "提交video任务已加入队列"}
|
120 |
+
|
121 |
return {"message": "Tasks added to the queue"}
|
122 |
|
123 |
|
|
|
157 |
|
158 |
await uploader.start()
|
159 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|