Bladeren bron

update bottom videos

liqian 3 jaren geleden
bovenliggende
commit
010a263118
3 gewijzigde bestanden met toevoegingen van 15 en 0 verwijderingen
  1. 2 0
      bottom_videos.py
  2. 2 0
      config.py
  3. 11 0
      db_helper.py

+ 2 - 0
bottom_videos.py

@@ -49,6 +49,8 @@ def update_bottom_videos():
 
         redis_helper = RedisHelper()
         redis_helper.add_data_with_zset(key_name=config_.BOTTOM_KEY_NAME, data=videos)
+        # 与原有兜底视频排序,保留top1000
+        redis_helper.remove_by_rank_from_zset(key_name=config_.BOTTOM_KEY_NAME, start=config_.BOTTOM_NUM, stop=-1)
         # 移除bottom key的过期时间,将其转换为永久状态
         redis_helper.persist_key(key_name=config_.BOTTOM_KEY_NAME)
 

+ 2 - 0
config.py

@@ -45,6 +45,8 @@ class BaseConfig(object):
 
     # 兜底视频redis存储key
     BOTTOM_KEY_NAME = 'com.weiqu.video.bottom'
+    # 兜底视频数量
+    BOTTOM_NUM = 1000
 
     # 修改ROV的视频 redis key
     UPDATE_ROV_KEY_NAME = 'com.weiqu.video.update.rov.item.score'

+ 11 - 0
db_helper.py

@@ -142,6 +142,17 @@ class RedisHelper(object):
         conn = self.connect()
         conn.zrem(key_name, value)
 
+    def remove_by_rank_from_zset(self, key_name, start, stop):
+        """
+        移除有序集中,指定排名(rank)区间内的所有成员
+        :param key_name: key
+        :param start: 开始位
+        :param stop: 结束位
+        :return: None
+        """
+        conn = self.connect()
+        conn.zremrangebyrank(name=key_name, min=start, max=stop)
+
     def get_index_with_data(self, key_name, value):
         """
         根据元素的值获取在有序set中的位置,按照分数倒序(从大到小)