Update api.py

api.py

@@ -31,7 +31,7 @@ def t5():
 
 
     
-
+##这个比较快不用异步
 @app.post("/getOriginalMangaList")
 async def getOriginalMangaList(images: List[UploadFile] = File(...)):
     for idx, image in enumerate(images):
@@ -40,8 +40,9 @@ async def getOriginalMangaList(images: List[UploadFile] = File(...)):
         path_to_image = f"/manga/{idx}.jpg"
         image.save(path_to_image)
     return "获取图片保存成功"
+##这个比较快不用异步
 
-
+##这个比较快不用异步
 @app.delete("/deleteFiles")
 async def delete_files(directory: str):
     for filename in os.listdir(directory):
@@ -49,17 +50,31 @@ async def delete_files(directory: str):
         if os.path.isfile(file_path):
             os.remove(file_path)
     return {"message": f"成功删除{directory}目录下的所有文件"}
+##这个比较快不用异步
 
 
-@app.get("/execute_py_file/{file_name}")
-async def execute_py_file(file_name: str):
+
+
+########异步处理py文件执行接口
+def file_executer(file_name:str)->"执行返回":
     try:
         result = subprocess.check_output(["python", f"{file_name}.py"]).decode("utf-8")
         return PlainTextResponse(result)
     except subprocess.CalledProcessError as e:
         return PlainTextResponse(f"Error executing {file_name}.py: {e}")
+    
+@app.get("/execute_py_file/{file_name}")
+async def execute_py_file(file_name: str,background_tasks: BackgroundTasks):
+    result = "接受到了请求{filename}任务".format(filename = file_name)
+    background_tasks.add_task(file_executer,file_name)
+    return result
+########异步处理py文件执行接口
+
+
+
 
 
+##########异步样例
 def someTask():
     time.sleep(20)
     print("睡眠20s结束")
@@ -70,4 +85,5 @@ def returnRandomSubscribeUrl(background_tasks: BackgroundTasks)->str:
     result = "先返回"
     background_tasks.add_task(someTask)
     return result
+##########异步样例