Merge branch 'feature_2023111711_liqian_add_abtest' into test

ad_roi_param_update.py

@@ -16,7 +16,7 @@ def update_ad_roi_param(param):
 if __name__ == '__main__':
     now_date = datetime.datetime.today()
     log_.info(f"now_date: {datetime.datetime.strftime(now_date, '%Y%m%d %H:%M:%S')}")
-    param = 5
+    param = 1.859871151 * 700
     log_.info(f"param = {param}")
     update_ad_roi_param(param=param)
     log_.info(f"ad roi param update finished!")

config.py

@@ -417,6 +417,19 @@ class BaseConfig(object):
             'rule24': {'view_type': 'video-show-region', 'platform_return_rate': 0.001, 'region_24h_rule_key': 'rule2',
                        '24h_rule_key': 'rule3', 'score_func': 'multiply_return_retention',
                        'return_data': 'share_region_return'},
+            # score = sharerate*backrate*log(return+1)*CTR,
+            # sharerate=(lastonehour_share+1)/(lastonehour_play+1000)
+            # backrate=(lastonehour_return+1)/(lastonehour_share+10)
+            # CTR=(lastonehour_play+1)/(lastonehour_view+100), ctr不进行校正
+            'rule25': {'view_type': 'video-view', 'platform_return_rate': 0.001, 'ctr_check': False,
+                       'region_24h_rule_key': 'rule4', '24h_rule_key': 'rule4', 'merge_func': 2,
+                       'score_func': 'back_view0'},
+            # score = back_play_rate*log(return+1)*CTR,
+            # back_play_rate=(lastonehour_return+1)/(lastonehour_play+1000)
+            # CTR=(lastonehour_play+1)/(lastonehour_view+100), ctr不进行校正
+            'rule26': {'view_type': 'video-view', 'platform_return_rate': 0.001, 'ctr_check': False,
+                       'region_24h_rule_key': 'rule4', '24h_rule_key': 'rule4', 'merge_func': 2,
+                       'score_func': 'back_view1'},
 
         },
         'data_params': DATA_PARAMS,
@@ -453,6 +466,8 @@ class BaseConfig(object):
             {'data': 'data1', 'rule': 'rule22'},  # 463 vlog 分值计算公式 增加h-2分享当前小时回流/h-2分享、h-3分享当前小时回流/h-3分享 特征
             # {'data': 'data1', 'rule': 'rule23'},  # 465 vlog 回流数据使用 分享限制地域，回流不限制地域 统计数据
             # {'data': 'data1', 'rule': 'rule24'},  # 466 vlog 分值计算公式 增加[h-3,h-2]之间的回流留存特征 + 回流数据使用 分享限制地域，回流不限制地域 统计数据
+            {'data': 'data10', 'rule': 'rule25'},  # 500
+            {'data': 'data10', 'rule': 'rule26'},  # 501
         ],
         'params_list_new': [
             # {'data': 'data10', 'rule': 'rule19'},  # 316 票圈视频 + 召回在线去重

flowpool_abtest_config_update.py

@@ -13,8 +13,8 @@ log_ = Log()
 
 flow_pool_abtest_config = {
     'control_group': [],
-    'experimental_flow_set_level': [],
-    'experimental_flow_set_level_score': [7, 8, 9, 10, 11, 12, 13, 14, 15, 16]
+    'experimental_flow_set_level': [12, 13, 14, 15, 16],
+    'experimental_flow_set_level_score':[7, 8, 9, 10, 11]
 }
 log_.info(f"flow_pool_abtest_config: {flow_pool_abtest_config}")
 redis_helper = RedisHelper()

region_rule_rank_h.py

@@ -33,15 +33,15 @@ features = [
     'apptype',
     'code',
     'videoid',
-    'lastonehour_preview',  # 过去1小时预曝光人数
-    'lastonehour_view',  # 过去1小时曝光人数
-    'lastonehour_play',  # 过去1小时播放人数
-    'lastonehour_share',  # 过去1小时分享人数
-    'lastonehour_return',  # 过去1小时分享，过去1小时回流人数
-    'lastonehour_preview_total',  # 过去1小时预曝光次数
-    'lastonehour_view_total',  # 过去1小时曝光次数
-    'lastonehour_play_total',  # 过去1小时播放次数
-    'lastonehour_share_total',  # 过去1小时分享次数
+    'lastonehour_preview',  # 过去1小时预曝光人数 - 区分地域
+    'lastonehour_view',  # 过去1小时曝光人数 - 区分地域
+    'lastonehour_play',  # 过去1小时播放人数 - 区分地域
+    'lastonehour_share',  # 过去1小时分享人数 - 区分地域
+    'lastonehour_return',  # 过去1小时分享，过去1小时回流人数 - 区分地域
+    'lastonehour_preview_total',  # 过去1小时预曝光次数 - 区分地域
+    'lastonehour_view_total',  # 过去1小时曝光次数 - 区分地域
+    'lastonehour_play_total',  # 过去1小时播放次数 - 区分地域
+    'lastonehour_share_total',  # 过去1小时分享次数 - 区分地域
     'platform_return',
     'lastonehour_show',  # 不区分地域
     'lastonehour_show_region',  # 地域分组
@@ -162,6 +162,7 @@ def cal_score_initial(df, param):
     else:
         df['ctr'] = df['lastonehour_play'] / (df['lastonehour_preview'] + 1000)
     df['K2'] = df['ctr'].apply(lambda x: 0.6 if x > 0.6 else x)
+
     df['platform_return_rate'] = df['platform_return'] / df['lastonehour_return']
 
     df['score1'] = df['share_rate'] * df['back_rate'] * df['log_back'] * df['K2']
@@ -348,6 +349,36 @@ def cal_score_multiply_return_retention_with_new_return(df, param):
     return df
 
 
+def cal_score_with_back_view0(df, param):
+    # score = sharerate*backrate*log(return+1)*CTR,
+    # sharerate=(lastonehour_share+1)/(lastonehour_play+1000)
+    # backrate=(lastonehour_return+1)/(lastonehour_share+10)
+    # CTR=(lastonehour_play+1)/(lastonehour_view+100), ctr不进行校正
+    df = df.fillna(0)
+    df['share_rate'] = (df['lastonehour_share'] + 1) / (df['lastonehour_play'] + 1000)
+    df['back_rate'] = (df['lastonehour_return'] + 1) / (df['lastonehour_share'] + 10)
+    df['log_back'] = (df['lastonehour_return'] + 1).apply(math.log)
+    df['ctr'] = (df['lastonehour_play'] + 1) / (df['lastonehour_view'] + 100)
+    df['platform_return_rate'] = df['platform_return'] / df['lastonehour_return']
+    df['score'] = df['share_rate'] * df['back_rate'] * df['log_back'] * df['ctr']
+    df = df.sort_values(by=['score'], ascending=False)
+    return df
+
+
+def cal_score_with_back_view1(df, param):
+    # score = back_play_rate*log(return+1)*CTR,
+    # back_play_rate=(lastonehour_return+1)/(lastonehour_play+1000)
+    # CTR=(lastonehour_play+1)/(lastonehour_view+100), ctr不进行校正
+    df = df.fillna(0)
+    df['back_play_rate'] = (df['lastonehour_return'] + 1) / (df['lastonehour_play'] + 1000)
+    df['log_back'] = (df['lastonehour_return'] + 1).apply(math.log)
+    df['ctr'] = (df['lastonehour_play'] + 1) / (df['lastonehour_view'] + 100)
+    df['platform_return_rate'] = df['platform_return'] / df['lastonehour_return']
+    df['score'] = df['back_play_rate'] * df['log_back'] * df['ctr']
+    df = df.sort_values(by=['score'], ascending=False)
+    return df
+
+
 def cal_score(df, param):
     if param.get('return_data', None) == 'share_region_return':
         if param.get('score_func', None) == 'multiply_return_retention':
@@ -361,6 +392,10 @@ def cal_score(df, param):
             df = cal_score_multiply_return_retention(df=df, param=param)
         elif param.get('score_func', None) == 'update_backrate':
             df = cal_score_update_backrate(df=df, param=param)
+        elif param.get('score_func', None) == 'back_view0':
+            df = cal_score_with_back_view0(df=df, param=param)
+        elif param.get('score_func', None) == 'back_view1':
+            df = cal_score_with_back_view1(df=df, param=param)
         else:
             df = cal_score_initial(df=df, param=param)
     return df