Update api.py

api.py

@@ -59,8 +59,20 @@ async def delete_files(directory: str):
 def file_executer(file_name:str)->"执行返回":
     try:
         print("开始执行py任务",file_name)
-        # result = subprocess.check_output(["python", f"{file_name}.py"]).decode("utf-8")
-        result = subprocess.check_output(["python", f"{file_name}.py"], stderr=subprocess.STDOUT).decode("utf-8")#显示运行中的print
+        # result = subprocess.check_output(["python", f"{file_name}.py"], stderr=subprocess.STDOUT).decode("utf-8")#执行完成后显示运行py的print
+        ##########test 边执行py边显示print+++++++++++++++++++++++++++++++++++++
+        # 开始执行Python 脚本
+        output = []
+        process = subprocess.Popen(["python", f"{file_name}.py"], stdout=subprocess.PIPE, stderr=subprocess.STDOUT)
+        # 逐行读取脚本的输出并显示
+        for line in iter(process.stdout.readline, b''):
+            line_text = line.decode('utf-8').strip()
+            print(line_text)
+            output.append(line_text)
+        process.wait()
+        result = '\n'.join(output)
+        ##########test 边执行py边显示print+++++++++++++++++++++++++++++++++++++
+        
         print("执行完成py任务:",file_name,"结果如下")
         print(result)
         return PlainTextResponse(result)