12345678910111213141516171819202122232425262728293031323334353637383940414243 |
- """
- @author: luojunhui
- """
- from applications.functions.log import logging
- # from applications.functions.common import MySQLServer
- async def recall_videos(trace_id, s_videos):
- """
- 通过请求的数据来召回视频
- :param s_videos:
- :param trace_id:
- :return: file_list
- """
- # title = params['title']
- # content = params['content']
- # ghId = params['ghId']
- # user_id = gh_id_dict[ghId]['uid']
- # 在两边召回视频
- # pq_videos
- # recall_video_list = MySQLServer().select_pq_videos()
- recall_video_list = []
- # dirs_1 = os.path.join(os.getcwd(), 'applications', 'static', 'out_videos')
- # file_list = [os.path.join(dirs_1, "{}.json".format(vid)) for vid in s_videos]
- # search_list = []
- # for file in file_list:
- # with open(file, encoding="utf-8") as f:
- # obj = json.loads(f.read())
- # if obj:
- # obj['video_id'] = file.split("/")[-1].replace('.json', '')
- # search_list.append(obj)
- logging(
- code="1002",
- info="召回视频",
- data={
- "pq_list": [],
- "search_list": s_videos
- },
- trace_id=trace_id
- )
- return recall_video_list, s_videos
|