不区分app权重的地域召回子策略离线数据生产

config.py

@@ -203,6 +203,19 @@ class BaseConfig(object):
         'data14': {APP_TYPE['VLOG']: 0.78, APP_TYPE['LOVE_LIVE']: 0.11, APP_TYPE['SHORT_VIDEO']: 0.08,
                    APP_TYPE['LONG_VIDEO']: 0.03},
         'videos5': {APP_TYPE['LONG_VIDEO']: 1},  # [内容精选]
+        'data66': {
+            APP_TYPE['VLOG']: 1,
+            APP_TYPE['LOVE_LIVE']: 1,
+            APP_TYPE['LONG_VIDEO']: 1,
+            APP_TYPE['SHORT_VIDEO']: 1,
+            APP_TYPE['WAN_NENG_VIDEO']: 1,
+            APP_TYPE['LAO_HAO_KAN_VIDEO']: 1,
+            APP_TYPE['ZUI_JING_QI']: 1,
+            APP_TYPE['APP']: 1,
+            APP_TYPE['PIAO_QUAN_VIDEO_PLUS']: 1,
+            APP_TYPE['JOURNEY']: 1,
+            APP_TYPE['BLESSING_YEAR']: 1
+        },
 
     }
 
@@ -470,8 +483,10 @@ class BaseConfig(object):
             'rule29': {'view_type': 'video-show-region', 'platform_return_rate': 0.001,
                        'region_24h_rule_key': 'rule4', '24h_rule_key': 'rule4', 'merge_func': 2,
                        'score_func': 'back_rate_rank_weighting'},
-
-
+            'rule66': {
+                'view_type': 'video-show-region', 'platform_return_rate': 0.001,
+                'region_24h_rule_key': 'rule4', '24h_rule_key': 'rule4', 'h_rule_key': 'rule1', 'merge_func': 66
+            },
         },
         'data_params': DATA_PARAMS,
         'params_list': [
@@ -513,6 +528,7 @@ class BaseConfig(object):
             {'data': 'data10', 'rule': 'rule28'},  # 503
             # {'data': 'data10', 'rule': 'rule29'},  # 509
             {'data': 'data10', 'rule': 'rule30'},  # 510
+            {'data': 'data66', 'rule': 'rule66'}, # 520
         ],
         'params_list_new': [
             # {'data': 'data10', 'rule': 'rule19'},  # 316 票圈视频 + 召回在线去重

rule_rank_h_by_24h.py

@@ -358,7 +358,11 @@ def rank_by_h(now_date, now_h, rule_params, project, table):
             video_rank_h(df=df_merged, now_date=now_date, now_h=now_h,
                          rule_key=rule_key, param=rule_param, data_key=data_key,
                          notify_backend=notify_backend)
-
+        elif merge_func == 66:
+            score_df = cal_score(df=feature_df, param=rule_param)
+            video_rank_h(df=score_df, now_date=now_date, now_h=now_h,
+                         rule_key=rule_key, param=rule_param, data_key=data_key,
+                         notify_backend=notify_backend)
         else:
             df_list = [feature_df[feature_df['apptype'] == apptype] for apptype, _ in data_param.items()]
             df_merged = reduce(merge_df, df_list)