merge recall-update-h

config.py

@@ -164,72 +164,72 @@ class BaseConfig(object):
     RULE_PARAMS_24H_APP_TYPE = {
         APP_TYPE['VLOG']: {
             'rule_params': {
-                'rule2': {'cal_score_func': 2, 'return_count': 100, 'platform_return_rate': 0.001,
+                'rule2': {'cal_score_func': 2, 'return_count': 80, 'platform_return_rate': 0.001,
+                          'view_type': 'preview'},
+            },
+            'data_params': {
+                'data1': [APP_TYPE['VLOG'], ],
+                'data2': [APP_TYPE['VLOG'], APP_TYPE['LOVE_LIVE'], APP_TYPE['LONG_VIDEO'], APP_TYPE['SHORT_VIDEO']],
+            }
+        },
+        APP_TYPE['LONG_VIDEO']: {
+            'rule_params': {
+                'rule2': {'cal_score_func': 2, 'return_count': 80, 'platform_return_rate': 0.001,
+                          'view_type': 'preview'},
+            },
+            'data_params': {
+                'data1': [APP_TYPE['VLOG'], ],
+                'data2': [APP_TYPE['LONG_VIDEO'], ],
+                'data3': [APP_TYPE['VLOG'], APP_TYPE['LONG_VIDEO'], ],
+                'data4': [APP_TYPE['VLOG'], APP_TYPE['LOVE_LIVE'], APP_TYPE['LONG_VIDEO'], APP_TYPE['SHORT_VIDEO']],
+            }
+        },
+        APP_TYPE['LOVE_LIVE']: {
+            'rule_params': {
+                'rule2': {'cal_score_func': 2, 'return_count': 80, 'platform_return_rate': 0.001,
+                          'view_type': 'preview'},
+
+            },
+            'data_params': {
+                'data1': [APP_TYPE['VLOG'], ],
+            }
+        },
+        APP_TYPE['SHORT_VIDEO']: {
+            'rule_params': {
+                'rule2': {'cal_score_func': 2, 'return_count': 80, 'platform_return_rate': 0.001,
+                          'view_type': 'preview'},
+            },
+            'data_params': {
+                'data1': [APP_TYPE['VLOG'], ],
+            }
+        },
+        APP_TYPE['LAO_HAO_KAN_VIDEO']: {
+            'rule_params': {
+                'rule2': {'cal_score_func': 2, 'return_count': 80, 'platform_return_rate': 0.001,
+                          'view_type': 'preview'},
+            },
+            'data_params': {
+                'data1': [APP_TYPE['VLOG'], ],
+            }
+        },
+        APP_TYPE['ZUI_JING_QI']: {
+            'rule_params': {
+                'rule2': {'cal_score_func': 2, 'return_count': 80, 'platform_return_rate': 0.001,
+                          'view_type': 'preview'},
+            },
+            'data_params': {
+                'data1': [APP_TYPE['VLOG'], ],
+            }
+        },
+        APP_TYPE['APP']: {
+            'rule_params': {
+                'rule2': {'cal_score_func': 2, 'return_count': 80, 'platform_return_rate': 0.001,
                           'view_type': 'preview'},
             },
             'data_params': {
                 'data1': [APP_TYPE['VLOG'], ],
-                # 'data2': [APP_TYPE['VLOG'], APP_TYPE['LOVE_LIVE'], APP_TYPE['LONG_VIDEO'], APP_TYPE['SHORT_VIDEO']],
             }
         },
-        # APP_TYPE['LONG_VIDEO']: {
-        #     'rule_params': {
-        #         'rule2': {'cal_score_func': 2, 'return_count': 100, 'platform_return_rate': 0.001,
-        #                   'view_type': 'preview'},
-        #     },
-        #     'data_params': {
-        #         'data1': [APP_TYPE['VLOG'], ],
-        #         'data2': [APP_TYPE['LONG_VIDEO'], ],
-        #         'data3': [APP_TYPE['VLOG'], APP_TYPE['LONG_VIDEO'], ],
-        #         'data4': [APP_TYPE['VLOG'], APP_TYPE['LOVE_LIVE'], APP_TYPE['LONG_VIDEO'], APP_TYPE['SHORT_VIDEO']],
-        #     }
-        # },
-        # APP_TYPE['LOVE_LIVE']: {
-        #     'rule_params': {
-        #         'rule2': {'cal_score_func': 2, 'return_count': 100, 'platform_return_rate': 0.001,
-        #                   'view_type': 'preview'},
-        #
-        #     },
-        #     'data_params': {
-        #         'data1': [APP_TYPE['VLOG'], ],
-        #     }
-        # },
-        # APP_TYPE['SHORT_VIDEO']: {
-        #     'rule_params': {
-        #         'rule2': {'cal_score_func': 2, 'return_count': 100, 'platform_return_rate': 0.001,
-        #                   'view_type': 'preview'},
-        #     },
-        #     'data_params': {
-        #         'data1': [APP_TYPE['VLOG'], ],
-        #     }
-        # },
-        # APP_TYPE['LAO_HAO_KAN_VIDEO']: {
-        #     'rule_params': {
-        #         'rule2': {'cal_score_func': 2, 'return_count': 100, 'platform_return_rate': 0.001,
-        #                   'view_type': 'preview'},
-        #     },
-        #     'data_params': {
-        #         'data1': [APP_TYPE['VLOG'], ],
-        #     }
-        # },
-        # APP_TYPE['ZUI_JING_QI']: {
-        #     'rule_params': {
-        #         'rule2': {'cal_score_func': 2, 'return_count': 100, 'platform_return_rate': 0.001,
-        #                   'view_type': 'preview'},
-        #     },
-        #     'data_params': {
-        #         'data1': [APP_TYPE['VLOG'], ],
-        #     }
-        # },
-        # APP_TYPE['APP']: {
-        #     'rule_params': {
-        #         'rule2': {'cal_score_func': 2, 'return_count': 100, 'platform_return_rate': 0.001,
-        #                   'view_type': 'preview'},
-        #     },
-        #     'data_params': {
-        #         'data1': [APP_TYPE['VLOG'], ],
-        #     }
-        # },
     }
 
     # 地域分组小时级更新24h使用数据  loghubods.video_each_day_update_province_24h_total_apptype
@@ -876,8 +876,8 @@ class ProductionConfig(BaseConfig):
 
 def set_config():
     # 获取环境变量 ROV_OFFLINE_ENV
-    # env = os.environ.get('ROV_OFFLINE_ENV')
-    env = 'pre'
+    env = os.environ.get('ROV_OFFLINE_ENV')
+    # env = 'dev'
     if env is None:
         # log_.error('ENV ERROR: is None!')
         return

rule_rank_h_by_24h.py

@@ -173,9 +173,9 @@ def video_rank_h(df, now_date, now_h, rule_key, param, app_type, data_key):
         f"{config_.RECALL_KEY_NAME_PREFIX_BY_24H}{app_type}.{data_key}.{rule_key}.{now_dt}.{now_h}"
     if len(day_recall_result) > 0:
         log_.info(f"count = {len(day_recall_result)}")
-        # redis_helper.add_data_with_zset(key_name=day_recall_key_name, data=day_recall_result, expire_time=23 * 3600)
+        redis_helper.add_data_with_zset(key_name=day_recall_key_name, data=day_recall_result, expire_time=23 * 3600)
         # 清空线上过滤应用列表
-        # redis_helper.del_keys(key_name=f"{config_.H_VIDEO_FILER_24H}{app_type}.{data_key}.{rule_key}")
+        redis_helper.del_keys(key_name=f"{config_.H_VIDEO_FILER_24H}{app_type}.{data_key}.{rule_key}")
 
     # 去重更新rov模型结果，并另存为redis中
     # initial_data_dup = {}