Merge branch 'feature/zhangbo_flow_recall' of algorithm/rov-offline into master

alg_recsys_recall_1h_region.py

@@ -24,8 +24,8 @@ RULE_PARAMS = {
     'rule_params': {
         'rule66': {
             'view_type': 'video-show-region',
-            'score_func': '20240223',
-            'lastonehour_allreturn': "1",
+            # 'score_func': '20240223',
+            # 'lastonehour_allreturn': "1",
             'region_24h_rule_key': 'rule66', '24h_rule_key': 'rule66'
         },
         'rule67': {

config.py

@@ -422,8 +422,8 @@ class BaseConfig(object):
                 # 'view_type': 'video-show-region', 'platform_return_rate': 0.001,
                 # 'view_type': 'video-show-region', "return_countv2": 1, 'platform_return_ratev2': 0.001,
                 'view_type': 'video-show-region',
-                'score_func': '20240223',
-                'lastonehour_allreturn': "1",
+                # 'score_func': '20240223',
+                # 'lastonehour_allreturn': "1",
                 'region_24h_rule_key': 'rule66', '24h_rule_key': 'rule66'
             },
             'rule68': {

region_rule_rank_h_v2.py

@@ -648,6 +648,7 @@ def video_rank(df, now_date, now_h, rule_key, param, region, data_key, rule_rank
         (df['platform_return_rate'] >= platform_return_rate)
         ]
     if "lastonehour_allreturn" in param.keys():
+        log_.info("采用 lastonehour_allreturn 过滤")
         h_recall_df = df[
             (df['lastonehour_allreturn'] > 0)
             ]