update

check_video_limit_distribute.py

@@ -231,8 +231,9 @@ def check_region_videos(rule_params):
         gevent.joinall(task_list)
 
     # 将已超分发视频 移除 天级更新30天列表
+    log_.info("day_by_30day check start...")
     day30_key_prefix = config_.RECALL_KEY_NAME_PREFIX_30DAY
-    for param in rule_params.get('params_list'):
+    for param in config_.RULE_PARAMS_30DAY_APP_TYPE.get('params_list'):
         data_key = param.get('data')
         rule_key = param.get('rule')
         log_.info(f"data_key = {data_key}, rule_key = {rule_key}")
@@ -241,6 +242,7 @@ def check_region_videos(rule_params):
             redis_date = now_date - datetime.timedelta(days=1)
             key_name = f"{day30_key_prefix}:{data_key}:{rule_key}:{datetime.datetime.strftime(redis_date, '%Y%m%d')}"
         redis_helper.remove_value_from_zset(key_name=key_name, value=stop_distribute_video_id_list)
+    log_.info("day_by_30day check end!")
 
     # 将已超分发视频 移除 原始大列表
     # key_name = f"{config_.RECALL_KEY_NAME_PREFIX}{datetime.datetime.strftime(now_date, '%Y%m%d')}"
@@ -251,5 +253,7 @@ def check_region_videos(rule_params):
 
 
 if __name__ == '__main__':
+    log_.info("start...")
     check_region_videos(rule_params=config_.RULE_PARAMS_REGION_APP_TYPE)
     # check_region_videos(rule_params=config_.RULE_PARAMS_REGION_APP_TYPE_48H)
+    log_.info("end!")