update

region_rule_rank_h_by24h.py

@@ -167,7 +167,7 @@ def video_rank(df, now_date, now_h, rule_key, param, region, data_key):
     h_recall_df['videoid'] = h_recall_df['videoid'].astype(int)
     h_recall_videos = h_recall_df['videoid'].to_list()
     log_.info(f'h_recall_videos count = {len(h_recall_videos)}')
-    log_.info('h_recall_videos:{}'.format('-'.join([str(i) for i in h_recall_videos])))
+    # log_.info('h_recall_videos:{}'.format('-'.join([str(i) for i in h_recall_videos])))
 
     # 视频状态过滤
     if data_key in ['data7', ]:
@@ -187,9 +187,9 @@ def video_rank(df, now_date, now_h, rule_key, param, region, data_key):
     day_recall_key_name = \
         f"{config_.RECALL_KEY_NAME_PREFIX_REGION_BY_24H}{region}:{data_key}:{rule_key}:" \
         f"{datetime.datetime.strftime(now_date, '%Y%m%d')}:{now_h}"
-    log_.info("day_recall_result.type:{}".format(str(type(day_recall_result))))
-    log_.info("begin to write redis for day_recall_key_name:{} with {}".format(day_recall_key_name,
-                                                                               str(len(day_recall_result))))
+    # log_.info("day_recall_result.type:{}".format(str(type(day_recall_result))))
+    # log_.info("begin to write redis for day_recall_key_name:{} with {}".format(day_recall_key_name,
+    #                                                                            str(len(day_recall_result))))
     if len(day_recall_result) > 0:
         redis_helper.add_data_with_zset(key_name=day_recall_key_name, data=day_recall_result, expire_time=2 * 3600)
         # 清空线上过滤应用列表

rule_rank_h_by_24h.py

@@ -197,7 +197,7 @@ def video_rank_h(df, now_date, now_h, rule_key, param, data_key, notify_backend)
         filtered_videos = filter_video_status_app(day_recall_videos)
     else:
         filtered_videos = filter_video_status(day_recall_videos)
-    log_.info('filtered_videos count = {}'.format(len(filtered_videos)))
+    # log_.info('filtered_videos count = {}'.format(len(filtered_videos)))
 
     # 写入对应的redis
     now_dt = datetime.strftime(now_date, '%Y%m%d')
@@ -212,7 +212,7 @@ def video_rank_h(df, now_date, now_h, rule_key, param, data_key, notify_backend)
 
     h_24h_recall_key_name = \
         f"{config_.RECALL_KEY_NAME_PREFIX_BY_24H}{data_key}:{rule_key}:{now_dt}:{now_h}"
-    log_.info("h_24h_recall_key_name:redis:{}".format(h_24h_recall_key_name))
+    # log_.info("h_24h_recall_key_name:redis:{}".format(h_24h_recall_key_name))
     if len(day_recall_result) > 0:
         log_.info(f"count = {len(day_recall_result)}, key = {h_24h_recall_key_name}")
         redis_helper.add_data_with_zset(key_name=h_24h_recall_key_name, data=day_recall_result, expire_time=2 * 3600)