|
@@ -295,7 +295,7 @@ class FilterVideos(object):
|
|
|
# 预曝光过滤
|
|
|
st_pre = time.time()
|
|
|
filtered_pre_result = self.filter_video_previewed(self.video_ids)
|
|
|
- print("filtered_pre:", (time.time()-st_pre)*1000)
|
|
|
+ # print("filtered_pre:", (time.time()-st_pre)*1000)
|
|
|
# et_pre = time.time()
|
|
|
# log_.info({
|
|
|
# 'logTimestamp': int(time.time() * 1000),
|
|
@@ -324,7 +324,7 @@ class FilterVideos(object):
|
|
|
# 视频已曝光过滤
|
|
|
st_viewed = time.time()
|
|
|
filtered_viewed_result = self.filter_video_viewed(video_ids=filtered_pre_result)
|
|
|
- print("filtered_pre:", (time.time() - st_viewed) * 1000)
|
|
|
+ # print("filtered_pre:", (time.time() - st_viewed) * 1000)
|
|
|
# et_viewed = time.time()
|
|
|
# log_.info({
|
|
|
# 'logTimestamp': int(time.time() * 1000),
|
|
@@ -363,7 +363,7 @@ class FilterVideos(object):
|
|
|
'shield_filter_result': filtered_shield_video_ids,
|
|
|
'executeTime': (time.time() - st_viewed) * 1000
|
|
|
})
|
|
|
- print("filtered_pre flow:", (time.time() - st_viewed) * 1000)
|
|
|
+ # print("filtered_pre flow:", (time.time() - st_viewed) * 1000)
|
|
|
return filtered_shield_video_ids
|
|
|
else:
|
|
|
return filtered_viewed_videos
|
|
@@ -450,13 +450,13 @@ class FilterVideos(object):
|
|
|
"uid": self.uid,
|
|
|
"types": list(types),
|
|
|
"videoIds": video_ids}
|
|
|
- print(request_data)
|
|
|
+ # print(request_data)
|
|
|
# 调用http接口
|
|
|
result = request_post(request_url=config_.VIDEO_FILTER_URL, request_data=request_data, timeout=(0.1, 1))
|
|
|
|
|
|
- print("result:", result)
|
|
|
+ # print("result:", result)
|
|
|
if result is None:
|
|
|
- print("result is None")
|
|
|
+ # print("result is None")
|
|
|
# log_.info('过滤失败,types: {}'.format(types))
|
|
|
return []
|
|
|
|
|
@@ -511,7 +511,7 @@ class FilterVideos(object):
|
|
|
:param shield_key_name_list: 过滤视频 redis-key
|
|
|
:return: filtered_videos 过滤后的列表 type-list
|
|
|
"""
|
|
|
- print("filter_shield_video:", len(filter_shield_video))
|
|
|
+ # print("filter_shield_video:", len(filter_shield_video))
|
|
|
if len(video_ids) == 0:
|
|
|
return video_ids
|
|
|
# 根据Redis缓存中的数据过滤
|
|
@@ -526,7 +526,7 @@ class FilterVideos(object):
|
|
|
# continue
|
|
|
# shield_videos = [int(video) for video in shield_videos_list]
|
|
|
# video_ids = [int(video_id) for video_id in video_ids if int(video_id) not in shield_videos]
|
|
|
- print("video_ids:", len(video_ids))
|
|
|
+ # print("video_ids:", len(video_ids))
|
|
|
return video_ids
|
|
|
|
|
|
def new_filter_video(self):
|