|
|
@@ -136,6 +136,8 @@ def filter_rov_pool(app_type=None):
|
|
|
log_.info("video_ids size = {}, filtered size = {}, filter sizer = {}".format(len(video_ids),
|
|
|
len(filtered_result),
|
|
|
len(filter_videos)))
|
|
|
+ log_.info({'key_name': key_name, 'filter_videos': filter_videos})
|
|
|
+
|
|
|
if len(filter_videos) == 0:
|
|
|
log_.info("rov recall pool filter end!")
|
|
|
return
|
|
|
@@ -220,6 +222,8 @@ def filter_flow_pool_18_19(app_type):
|
|
|
filter_videos = set(video_ids) - set(filtered_result)
|
|
|
log_.info("data size = {}, video_ids size = {}, filtered size = {}, filter sizer = {}".format(
|
|
|
len(data), len(video_ids), len(filtered_result), len(filter_videos)))
|
|
|
+ log_.info({'key_name': key_name, 'filter_videos': filter_videos})
|
|
|
+
|
|
|
# 移除
|
|
|
if len(filter_videos) == 0:
|
|
|
log_.info("app_type {} videos filter end!".format(app_type))
|
|
|
@@ -247,6 +251,7 @@ def filter_bottom():
|
|
|
log_.info("video_ids size = {}, filtered size = {}, filter sizer = {}".format(len(video_ids),
|
|
|
len(filtered_result),
|
|
|
len(filter_videos)))
|
|
|
+
|
|
|
if len(filter_videos) == 0:
|
|
|
log_.info("bottom videos filter end!")
|
|
|
return
|
|
|
@@ -272,6 +277,8 @@ def filter_rov_updated():
|
|
|
log_.info("video_ids size = {}, filtered size = {}, filter sizer = {}".format(len(video_ids),
|
|
|
len(filtered_result),
|
|
|
len(filter_videos)))
|
|
|
+ log_.info({'key_name': config_.UPDATE_ROV_KEY_NAM, 'filter_videos': filter_videos})
|
|
|
+
|
|
|
if len(filter_videos) == 0:
|
|
|
log_.info("update rov videos filter end!")
|
|
|
return
|
|
|
@@ -417,6 +424,8 @@ def filter_app_pool():
|
|
|
log_.info("video_ids size = {}, filtered size = {}, filter sizer = {}".format(len(video_ids),
|
|
|
len(filtered_result),
|
|
|
len(filter_videos)))
|
|
|
+ log_.info({'key_name': key_name, 'filter_videos': filter_videos})
|
|
|
+
|
|
|
if len(filter_videos) == 0:
|
|
|
log_.info("app pool filter end!")
|
|
|
return
|
|
|
@@ -456,6 +465,8 @@ def filter_rov_h():
|
|
|
log_.info("video_ids size = {}, filtered size = {}, filter sizer = {}".format(len(video_ids),
|
|
|
len(filtered_result),
|
|
|
len(filter_videos)))
|
|
|
+ log_.info({'key_name': key_name, 'filter_videos': filter_videos})
|
|
|
+
|
|
|
if len(filter_videos) == 0:
|
|
|
log_.info("filter end!")
|
|
|
continue
|
|
|
@@ -501,6 +512,7 @@ def filter_rov_day():
|
|
|
log_.info("video_ids size = {}, filtered size = {}, filter sizer = {}".format(len(video_ids),
|
|
|
len(filtered_result),
|
|
|
len(filter_videos)))
|
|
|
+ log_.info({'key_name': key_name, 'filter_videos': filter_videos})
|
|
|
if len(filter_videos) == 0:
|
|
|
log_.info("filter end!")
|
|
|
continue
|
|
|
@@ -579,6 +591,8 @@ def filter_region_videos():
|
|
|
log_.info("video_ids size = {}, filtered size = {}, filter sizer = {}".format(len(video_ids),
|
|
|
len(filtered_result),
|
|
|
len(filter_videos)))
|
|
|
+ log_.info({'key_name': key_name, 'filter_videos': filter_videos})
|
|
|
+
|
|
|
if len(filter_videos) == 0:
|
|
|
log_.info("filter end!")
|
|
|
continue
|
|
|
@@ -626,6 +640,8 @@ def filter_region_videos_by_day():
|
|
|
log_.info("video_ids size = {}, filtered size = {}, filter sizer = {}".format(len(video_ids),
|
|
|
len(filtered_result),
|
|
|
len(filter_videos)))
|
|
|
+ log_.info({'key_name': key_name, 'filter_videos': filter_videos})
|
|
|
+
|
|
|
if len(filter_videos) == 0:
|
|
|
log_.info("filter end!")
|
|
|
continue
|
|
|
@@ -666,6 +682,8 @@ def filter_rov_h_24h():
|
|
|
log_.info("video_ids size = {}, filtered size = {}, filter sizer = {}".format(len(video_ids),
|
|
|
len(filtered_result),
|
|
|
len(filter_videos)))
|
|
|
+ log_.info({'key_name': key_name, 'filter_videos': filter_videos})
|
|
|
+
|
|
|
if len(filter_videos) == 0:
|
|
|
log_.info("filter end!")
|
|
|
continue
|
