|
|
@@ -121,6 +121,7 @@ def threshold_update(project, table, dt, app_type):
|
|
|
predict_mean = predict_df['res_predict'].mean()
|
|
|
for ab_code, param in record.items():
|
|
|
threshold = predict_mean * param
|
|
|
+ print(f"{abtest_id}-{ab_code}: {threshold}")
|
|
|
# 写入redis
|
|
|
threshold_key = f"{xgb_config['threshold_key_prefix']}{abtest_id}:{ab_code}"
|
|
|
redis_helper.set_data_to_redis(key_name=threshold_key, value=threshold, expire_time=48 * 3600)
|
