debug

db_helper.py

@@ -281,6 +281,7 @@ class MysqlHelper(object):
 
 if __name__ == '__main__':
     redis_helper = RedisHelper()
-    key = 'com.weiqu.video.hot.recommend.item.score.20210901'
-    res = redis_helper.get_score_with_value(key, 90797)
-    print(res)
+    # key = 'com.weiqu.video.hot.recommend.item.score.20210901'
+    # res = redis_helper.get_score_with_value(key, 90797)
+    # print(res)
+    redis_helper.remove_value_from_set(key_name=config_.RELEVANT_TOP_VIDEOS_KEY_NAME, values=(8633849,))

videos_filter.py

@@ -46,7 +46,7 @@ def filter_relevant_videos():
         # 保留可推荐 且生效中 的视频
         relevant_videos_new = [
             item for item in relevant_videos
-            if int(item['recommend_vid']) in filtered_videos and int(item['finish_time']) <= int(time.time())
+            if int(item['recommend_vid']) in filtered_videos and int(item['finish_time']) > int(time.time())
         ]
 
         # 过滤后没有符合的视频，将head_vid移除对应redis，删除对应的相关推荐的key
@@ -72,6 +72,10 @@ def filter_relevant_videos():
                 head_vid, len(relevant_videos_new)))
 
     # 将需要移除的头部视频id进行移除
+    if len(remove_head_vids) == 0:
+        log_.info('head videos remove finished! remove_head_vids = {}'.format(remove_head_vids))
+        log_.info("relevant videos with op filter end!")
+        return
     redis_helper.remove_value_from_set(key_name=config_.RELEVANT_TOP_VIDEOS_KEY_NAME, values=tuple(remove_head_vids))
     log_.info('head videos remove finished! remove_head_vids = {}'.format(remove_head_vids))
     log_.info("relevant videos with op filter end!")