liqian 2 年之前
父節點
當前提交
dc518ddf29
共有 3 個文件被更改,包括 7 次插入3 次删除
  1. 3 1
      region_rule_rank_h.py
  2. 2 1
      region_rule_rank_h_by24h.py
  3. 2 1
      rule_rank_h_by_24h.py

+ 3 - 1
region_rule_rank_h.py

@@ -345,7 +345,9 @@ def rank_by_h(project, table, now_date, now_h, rule_params, region_code_list):
                        "region_code": region,
                        "redis_key_prefix": config_.RECALL_KEY_NAME_PREFIX_REGION_BY_H,
                        "rule_key": key,
-                       "score_df": score_df[['videoid', 'score']]})
+                       # "score_df": score_df[['videoid', 'score']]
+                       }
+                      )
 
 
 def h_rank_bottom(now_date, now_h, rule_key, region_code_list, param):

+ 2 - 1
region_rule_rank_h_by24h.py

@@ -223,7 +223,8 @@ def rank_by_24h(project, table, now_date, now_h, rule_params, region_code_list):
                        "region_code": region,
                        "redis_key_prefix": config_.RECALL_KEY_NAME_PREFIX_REGION_BY_24H,
                        "rule_key": key,
-                       "score_df": score_df[['videoid', 'score']]})
+                       # "score_df": score_df[['videoid', 'score']]
+                       })
 
 
 def dup_to_redis(h_video_ids, now_date, now_h, rule_key, region):

+ 2 - 1
rule_rank_h_by_24h.py

@@ -204,7 +204,8 @@ def rank_by_h(now_date, now_h, rule_params, project, table):
         log_.info({"date": datetime.strftime(now_date, '%Y%m%d%H'),
                    "redis_key_prefix": config_.RECALL_KEY_NAME_PREFIX_BY_24H,
                    "rule_key": key,
-                   "score_df": score_df[['videoid', 'score']]})
+                   # "score_df": score_df[['videoid', 'score']]
+                   })
 
 
 def h_rank_bottom(now_date, now_h, rule_key):