|
@@ -55,43 +55,6 @@ def startup_event():
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
-@app.post("/decodeWorkflow/create")
|
|
|
|
|
-def decode_list():
|
|
|
|
|
- logger.info(f"数据池数据 = {video_list}")
|
|
|
|
|
- data_list = []
|
|
|
|
|
-
|
|
|
|
|
-
|
|
|
|
|
- for video in video_list:
|
|
|
|
|
- video_id = video.video_id
|
|
|
|
|
- video_url = video.video_url
|
|
|
|
|
- video_title = video.title
|
|
|
|
|
- task_id = str(uuid.uuid4())
|
|
|
|
|
- DecodeWorkflow(
|
|
|
|
|
- task_id=task_id,
|
|
|
|
|
- video_id=video_id,
|
|
|
|
|
- video_url=video_url,
|
|
|
|
|
- title=video_title,
|
|
|
|
|
- type=param.type,
|
|
|
|
|
- result=None,
|
|
|
|
|
- ).save()
|
|
|
|
|
- data_list.append({
|
|
|
|
|
- "task_id": task_id,
|
|
|
|
|
- "video_id": video_id,
|
|
|
|
|
- "video_url": video_url,
|
|
|
|
|
- "title": video_title,
|
|
|
|
|
- "task_status": 0,
|
|
|
|
|
- "type": param.type,
|
|
|
|
|
- })
|
|
|
|
|
- return {
|
|
|
|
|
- "code": 0,
|
|
|
|
|
- "message": "success",
|
|
|
|
|
- "data":{
|
|
|
|
|
- "type": param.type,
|
|
|
|
|
- "tasks": data_list
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
-
|
|
|
|
|
|
|
|
|
|
@app.post("/decodeWorkflow/create")
|
|
@app.post("/decodeWorkflow/create")
|
|
|
def decode_topic(param:TopicListParam):
|
|
def decode_topic(param:TopicListParam):
|