|  | @@ -0,0 +1,46 @@
 | 
	
		
			
				|  |  | +
 | 
	
		
			
				|  |  | +import datetime
 | 
	
		
			
				|  |  | +import traceback
 | 
	
		
			
				|  |  | +from threading import Timer
 | 
	
		
			
				|  |  | +from utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
 | 
	
		
			
				|  |  | +from config import set_config
 | 
	
		
			
				|  |  | +from log import Log
 | 
	
		
			
				|  |  | +config_, _ = set_config()
 | 
	
		
			
				|  |  | +log_ = Log()
 | 
	
		
			
				|  |  | +redis_helper = RedisHelper()
 | 
	
		
			
				|  |  | +
 | 
	
		
			
				|  |  | +if __name__ == '__main__':
 | 
	
		
			
				|  |  | +    dt = '20231203'
 | 
	
		
			
				|  |  | +    data_key = 'test_lr_v1'
 | 
	
		
			
				|  |  | +    key_name = f"{config_.KEY_NAME_PREFIX_AD_GROUP}{data_key}:{dt}"
 | 
	
		
			
				|  |  | +    redis_data = {
 | 
	
		
			
				|  |  | +        'yxh': 0.3,
 | 
	
		
			
				|  |  | +        'zb': 0.13213231231,
 | 
	
		
			
				|  |  | +    }
 | 
	
		
			
				|  |  | +    redis_data = {
 | 
	
		
			
				|  |  | +        'mz': 0.2,
 | 
	
		
			
				|  |  | +        'zb': 0.6666,
 | 
	
		
			
				|  |  | +    }
 | 
	
		
			
				|  |  | +    print(key_name)
 | 
	
		
			
				|  |  | +    #redis_helper.add_data_with_zset(key_name=key_name, data=redis_data, expire_time=2 * 24 * 3600)
 | 
	
		
			
				|  |  | +    print(redis_helper.get_score_with_value(key_name=key_name, value='zb'))
 | 
	
		
			
				|  |  | +    print(redis_helper.get_score_with_value(key_name=key_name, value='mz'))
 | 
	
		
			
				|  |  | +    print(redis_helper.get_score_with_value(key_name='ad:users:group:predict:share:rate:test_lr_v1:20231129', value='16537775'))
 | 
	
		
			
				|  |  | +    
 | 
	
		
			
				|  |  | +    model_key = 'ad_out_v1'
 | 
	
		
			
				|  |  | +    KEY_NAME_PREFIX_AD_OUT_MODEL_CONFIG = 'ad:out:model:config:'
 | 
	
		
			
				|  |  | +    abtest_id = '173'
 | 
	
		
			
				|  |  | +    abtest_config_tag = 'u'
 | 
	
		
			
				|  |  | +    config_key_prefix = f"{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"
 | 
	
		
			
				|  |  | +    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.4, expire_time)
 | 
	
		
			
				|  |  | +    redis_helper.set_data_to_redis(use_mean_key, 1, expire_time)
 | 
	
		
			
				|  |  | +    print(threshold_key)
 | 
	
		
			
				|  |  | +    print(use_mean_key)
 | 
	
		
			
				|  |  | +
 |