ad_no_ad_videos_update.py

@@ -47,11 +47,19 @@ def update_to_redis(no_ad_videos_mapping_list):
                 for k, val in item.items():
                     redis_data[app_type][k] = val
     # to redis
+    no_ad_app_type_list = []
     redis_helper = RedisHelper()
     for app_type, data in redis_data.items():
         key_name = f"{config_.KEY_NAME_PREFIX_NO_AD_VIDEOS}{app_type}"
         redis_helper.set_data_to_redis(key_name=key_name, value=json.dumps(data), expire_time=int(24*3600))
         log_.info(f"to redis: app_type={app_type}, data={data}, key_name={key_name}")
+        no_ad_app_type_list.append(int(app_type))
+    # 此次无符合要求数据的app_type清空对应数据
+    for _, app_type in config_.APP_TYPE.items():
+        if app_type not in no_ad_app_type_list:
+            key_name = f"{config_.KEY_NAME_PREFIX_NO_AD_VIDEOS}{app_type}"
+            redis_helper.del_keys(key_name=key_name)
+            log_.info(f"del from redis: app_type={app_type}, key_name={key_name}")
 
 
 def main():

ad_out_v1_set_config.py

@@ -11,20 +11,32 @@ redis_helper = RedisHelper()
 
 if __name__ == '__main__':
     model_key = 'ad_out_v1'
-    abtest_id = '173'
-    abtest_config_tag_list = ['u', 'v']
-    for abtest_config_tag in abtest_config_tag_list :
+    configs = {
+        '173-u': {
+            'threshold': 0.26,
+            'item_threshold': 0.3957,
+            'user_threshold': 0.3272,
+            'miss_threshold': 0.0,
+            'use_backup': 'true'
+        },
+        '173-v': {
+            'threshold': 0.273169,
+            'item_threshold': 0.402544,
+            'user_threshold': 0.334571,
+            'miss_threshold': 0.0,
+            'use_backup': 'false'
+        },
+    }
+    # abtest_id = '173'
+    # abtest_config_tag_list = ['u', 'v']
+    expire_time = 30 * 24 * 3600
+    for abtest_key, abtest_config in configs.items():
+        print(abtest_key)
+        abtest_id, abtest_config_tag = abtest_key.split('-')
         config_key_prefix = f"{config_.KEY_NAME_PREFIX_AD_OUT_MODEL_CONFIG}{model_key}:{abtest_id}:{abtest_config_tag}"
-        threshold_key = f"{config_key_prefix}:threshold"
-        use_mean_key = f"{config_key_prefix}:use_mean"
-        print(threshold_key)
-        threshold = redis_helper.get_data_from_redis(key_name=threshold_key)
-        use_mean = redis_helper.get_data_from_redis(key_name=use_mean_key)
-        print('threshold:', threshold, type(threshold))
-        print('use_mean:', use_mean, type(use_mean))
-        expire_time = 30 * 24 * 3600
-        redis_helper.set_data_to_redis(threshold_key, 0.27, expire_time)
-        redis_helper.set_data_to_redis(use_mean_key, 'false', expire_time)
-        print(threshold_key)
-        print(use_mean_key)
+        for k, v in abtest_config.items():
+            k_key = f"{config_key_prefix}:{k}"
+            k_value = redis_helper.get_data_from_redis(key_name=k_key)
+            print(k_key, k_value, type(k_value))
+            redis_helper.set_data_to_redis(k_key, v, expire_time)