recall.py 1.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243
  1. """
  2. @author: luojunhui
  3. """
  4. from applications.functions.log import logging
  5. # from applications.functions.common import MySQLServer
  6. async def recall_videos(trace_id, s_videos):
  7. """
  8. 通过请求的数据来召回视频
  9. :param s_videos:
  10. :param trace_id:
  11. :return: file_list
  12. """
  13. # title = params['title']
  14. # content = params['content']
  15. # ghId = params['ghId']
  16. # user_id = gh_id_dict[ghId]['uid']
  17. # 在两边召回视频
  18. # pq_videos
  19. # recall_video_list = MySQLServer().select_pq_videos()
  20. recall_video_list = []
  21. # dirs_1 = os.path.join(os.getcwd(), 'applications', 'static', 'out_videos')
  22. # file_list = [os.path.join(dirs_1, "{}.json".format(vid)) for vid in s_videos]
  23. # search_list = []
  24. # for file in file_list:
  25. # with open(file, encoding="utf-8") as f:
  26. # obj = json.loads(f.read())
  27. # if obj:
  28. # obj['video_id'] = file.split("/")[-1].replace('.json', '')
  29. # search_list.append(obj)
  30. logging(
  31. code="1002",
  32. info="召回视频",
  33. data={
  34. "pq_list": [],
  35. "search_list": s_videos
  36. },
  37. trace_id=trace_id
  38. )
  39. return recall_video_list, s_videos