From 2b1f542577dd8dfc54d3433dff3615796ceab0af Mon Sep 17 00:00:00 2001 From: shikeying <shikeying@163.com> Date: 星期二, 11 十月 2022 17:17:50 +0800 Subject: [PATCH] 视频下载,解析分析调度跑通 --- recommend-video/src/main/java/com/iplatform/recvideo/support/DefaultSimilarExecutor.java | 9 ++++++++- 1 files changed, 8 insertions(+), 1 deletions(-) diff --git a/recommend-video/src/main/java/com/iplatform/recvideo/support/DefaultSimilarExecutor.java b/recommend-video/src/main/java/com/iplatform/recvideo/support/DefaultSimilarExecutor.java index ceec831..10876e8 100644 --- a/recommend-video/src/main/java/com/iplatform/recvideo/support/DefaultSimilarExecutor.java +++ b/recommend-video/src/main/java/com/iplatform/recvideo/support/DefaultSimilarExecutor.java @@ -52,7 +52,9 @@ @Override protected String requestStartPythonLoadVideo(String batchId) throws Exception { logger.info("寮�濮嬭姹俻ython鏈嶅姟:" + Constants.AI_SERVICE_VIDEO_LOAD); - return null; + String url = this.remoteUrl + Constants.AI_SERVICE_VIDEO_LOAD; + boolean success = PythonInvokeUtils.postLoadVideoGather(batchId, url, this.restTemplate); + return success? null : "python 鍔犺浇瑙嗛璋冪敤澶辫触"; } @Override @@ -138,6 +140,11 @@ logger.debug("鎵规浠诲姟鐘舵�佸凡鏇存柊鎴愬姛! " + batchId); } + @Override + protected void ignoreTaskStatus(String batchId) { + this.videoExecutorService.execIgnoreTaskStatus(batchId); + } + private List<Rc_video_user> toRcVideoUserList(List<SimilarVideoUser> similarVideoUserList){ if(StringUtils.isEmptyList(similarVideoUserList)){ return null; -- Gitblit v1.9.1