|
|
@@ -1,3 +1,5 @@
|
|
|
+import time
|
|
|
+
|
|
|
import pandas as pd
|
|
|
import multiprocessing
|
|
|
import math
|
|
|
@@ -223,11 +225,12 @@ def video_rank_h(df, now_date, now_h, rule_key, param, data_key, notify_backend)
|
|
|
all_videos = df['videoid'].to_list()
|
|
|
log_.info(f'h_by24h_recall all videos count = {len(all_videos)}')
|
|
|
# 视频状态过滤
|
|
|
+ st_time = time.time()
|
|
|
if data_key in ['data7', ]:
|
|
|
all_filtered_videos = filter_video_status_app(all_videos)
|
|
|
else:
|
|
|
all_filtered_videos = filter_video_status(all_videos)
|
|
|
- log_.info(f'all_filtered_videos count = {len(all_filtered_videos)}')
|
|
|
+ log_.info(f'all_filtered_videos count = {len(all_filtered_videos)}, param = {param}, execute_time = {int(time.time() - st_time)*1000}ms')
|
|
|
# 与筛选结果去重
|
|
|
other_videos = [video for video in all_filtered_videos if video not in day_video_ids]
|
|
|
log_.info(f'other_videos count = {len(other_videos)}')
|
liqian