Update api.py

api.py

@@ -12,6 +12,7 @@ from fastapi.responses import PlainTextResponse #执行其他py的plaintext返
 import subprocess
 from fastapi import BackgroundTasks
 import time
+from bilibili_api import sync, video_uploader, Credential#bili上传部分
 app = FastAPI()
 
 @app.get("/inference")
@@ -123,4 +124,35 @@ def returnRandomSubscribeUrl(background_tasks: BackgroundTasks)->str:
     background_tasks.add_task(someTask)
     return result
 ##########异步样例
-    
+
+
+
+
+sessdata = os.getenv('sessdata')
+bili_jct = os.getenv('bili_jct')
+buvid3 = os.getenv('buvid3')
+async def upload_video():
+    credential = Credential(sessdata=sessdata,
+                            bili_jct=bili_jct,
+                            buvid3=buvid3)
+    
+    
+    page = video_uploader.VideoUploaderPage(path='mp4_out/output_video.mp4', title=meta['title'], description=meta['desc'])
+    
+    uploader = video_uploader.VideoUploader([page], meta, credential, cover='cover.jpg')
+
+    @uploader.on("__ALL__")
+    async def ev(data):
+        print(data)
+
+    await uploader.start()
+
+@app.post("/upload_video")
+async def run_upload_video(meta: dict = Body(...),cover_image: UploadFile = File(...), save_path: str = "/cover"):
+    cover_img = cover_image.file.read()
+    cover_img_data = Image.open(io.BytesIO(img)).convert("L").convert("RGB")
+    path_to_image = os.path.join(save_path, f"cover.jpg")
+    cover_img_data.save(path_to_image)
+    #video数据从meta用户请求获取,至于
+    await upload_video(meta)
+    return {"message": "Video upload completed"}