debug

region_rule_rank_h.py

@@ -373,6 +373,8 @@ def h_rank_bottom(now_date, now_h, rule_key, region_code_list, param):
         log_.info(f"region = {region}")
         key_name = f"{key_prefix}{region}.{rule_key}.{redis_dt}.{redis_h}"
         initial_data = redis_helper.get_all_data_from_zset(key_name=key_name, with_scores=True)
+        if initial_data is None:
+            initial_data = []
         final_data = dict()
         h_video_ids = []
         for video_id, score in initial_data:

region_rule_rank_h_by24h.py

@@ -282,6 +282,8 @@ def h_rank_bottom(now_date, now_h, rule_key, region_code_list):
         log_.info(f"region = {region}")
         key_name = f"{key_prefix}{region}.{rule_key}.{redis_dt}.{redis_h}"
         initial_data = redis_helper.get_all_data_from_zset(key_name=key_name, with_scores=True)
+        if initial_data is None:
+            initial_data = []
         final_data = dict()
         h_video_ids = []
         for video_id, score in initial_data:

rule_rank_h.py

@@ -264,6 +264,8 @@ def h_rank_bottom(now_date, now_h, rule_key):
     for key_prefix in key_prefix_list:
         key_name = f"{key_prefix}{rule_key}.{redis_dt}.{redis_h}"
         initial_data = redis_helper.get_all_data_from_zset(key_name=key_name, with_scores=True)
+        if initial_data is None:
+            initial_data = []
         final_data = dict()
         h_video_ids = []
         for video_id, score in initial_data:

rule_rank_h_by_24h.py

@@ -133,6 +133,8 @@ def video_rank_h(df, now_date, now_h, rule_key, param):
     redis_helper = RedisHelper()
     key_name = get_rov_redis_key(now_date=now_date)
     initial_data = redis_helper.get_all_data_from_zset(key_name=key_name, with_scores=True)
+    if initial_data is None:
+        initial_data = []
     log_.info(f'initial data count = {len(initial_data)}')
 
     # 获取符合进入召回源条件的视频
@@ -220,6 +222,8 @@ def h_rank_bottom(now_date, now_h, rule_key):
     for key_prefix in key_prefix_list:
         key_name = f"{key_prefix}{rule_key}.{redis_dt}.{redis_h}"
         initial_data = redis_helper.get_all_data_from_zset(key_name=key_name, with_scores=True)
+        if initial_data is None:
+            initial_data = []
         final_data = dict()
         for video_id, score in initial_data:
             final_data[video_id] = score