|
@@ -108,7 +108,7 @@ check_run_status() {
|
|
if [ $status -ne 0 ]; then
|
|
if [ $status -ne 0 ]; then
|
|
echo "$LOG_PREFIX -- ${step_name}失败: 耗时 $step_elapsed"
|
|
echo "$LOG_PREFIX -- ${step_name}失败: 耗时 $step_elapsed"
|
|
local elapsed=$(($step_end_time - $start_time))
|
|
local elapsed=$(($step_end_time - $start_time))
|
|
- /root/anaconda3/bin/python ad/ad_monitor_util.py --level error --msg "$msg" --start "$start_time" --elapsed "$elapsed"
|
|
|
|
|
|
+ # /root/anaconda3/bin/python ad/ad_monitor_util.py --level error --msg "$msg" --start "$start_time" --elapsed "$elapsed"
|
|
exit 1
|
|
exit 1
|
|
else
|
|
else
|
|
echo "$LOG_PREFIX -- ${step_name}成功: 耗时 $step_elapsed"
|
|
echo "$LOG_PREFIX -- ${step_name}成功: 耗时 $step_elapsed"
|
|
@@ -133,7 +133,7 @@ check_ad_hive() {
|
|
if (( current_hour > max_hour || (current_hour == max_hour && current_minute >= max_minute) )); then
|
|
if (( current_hour > max_hour || (current_hour == max_hour && current_minute >= max_minute) )); then
|
|
local msg="大数据数据生产校验失败, 分区: ${today}10"
|
|
local msg="大数据数据生产校验失败, 分区: ${today}10"
|
|
echo -e "$LOG_PREFIX -- 大数据数据生产校验 -- ${msg}: 耗时 $elapsed"
|
|
echo -e "$LOG_PREFIX -- 大数据数据生产校验 -- ${msg}: 耗时 $elapsed"
|
|
- /root/anaconda3/bin/python ad/ad_monitor_util.py --level error --msg "$msg" --start "$start_time" --elapsed "$elapsed"
|
|
|
|
|
|
+ # /root/anaconda3/bin/python ad/ad_monitor_util.py --level error --msg "$msg" --start "$start_time" --elapsed "$elapsed"
|
|
exit 1
|
|
exit 1
|
|
fi
|
|
fi
|
|
done
|
|
done
|
|
@@ -239,7 +239,7 @@ auc_compare() {
|
|
local msg="新模型与线上模型差值大于等于阈值0.005或新模型的AUC小于0.73 \n\t线上模型AUC: ${online_auc} \n\t新模型AUC: ${new_auc} \n\t差值为: $auc_diff"
|
|
local msg="新模型与线上模型差值大于等于阈值0.005或新模型的AUC小于0.73 \n\t线上模型AUC: ${online_auc} \n\t新模型AUC: ${new_auc} \n\t差值为: $auc_diff"
|
|
echo -e "$LOG_PREFIX -- $msg: 耗时 $step5_elapsed"
|
|
echo -e "$LOG_PREFIX -- $msg: 耗时 $step5_elapsed"
|
|
local elapsed=$(($step_end_time - $start_time))
|
|
local elapsed=$(($step_end_time - $start_time))
|
|
- /root/anaconda3/bin/python ad/ad_monitor_util.py --level error --msg "$msg" --start "$start_time" --elapsed "$elapsed"
|
|
|
|
|
|
+ # /root/anaconda3/bin/python ad/ad_monitor_util.py --level error --msg "$msg" --start "$start_time" --elapsed "$elapsed"
|
|
exit 1
|
|
exit 1
|
|
fi
|
|
fi
|
|
}
|
|
}
|
|
@@ -301,7 +301,7 @@ success_inform() {
|
|
local msg="\n\t - 广告模型文件更新完成 \n\t - 前一天线上模型全天数据AUC: $yesterday_online_auc \n\t - 前一天新模型全天数据AUC: $yesterday_new_auc \n\t - 新模型AUC: $new_auc \n\t - 线上模型AUC: $online_auc \n\t - AUC差值: $auc_diff \n\t - 模型上传路径: $online_model_path"
|
|
local msg="\n\t - 广告模型文件更新完成 \n\t - 前一天线上模型全天数据AUC: $yesterday_online_auc \n\t - 前一天新模型全天数据AUC: $yesterday_new_auc \n\t - 新模型AUC: $new_auc \n\t - 线上模型AUC: $online_auc \n\t - AUC差值: $auc_diff \n\t - 模型上传路径: $online_model_path"
|
|
echo -e "$LOG_PREFIX -- 模型更新完成 -- $msg: 耗时 $step_elapsed"
|
|
echo -e "$LOG_PREFIX -- 模型更新完成 -- $msg: 耗时 $step_elapsed"
|
|
local elapsed=$(($(date +%s -d "$step_end_time") - $(date +%s -d "$start_time")))
|
|
local elapsed=$(($(date +%s -d "$step_end_time") - $(date +%s -d "$start_time")))
|
|
- /root/anaconda3/bin/python ad/ad_monitor_util.py --level info --msg "$msg" --start "$start_time" --elapsed "$elapsed"
|
|
|
|
|
|
+ # /root/anaconda3/bin/python ad/ad_monitor_util.py --level info --msg "$msg" --start "$start_time" --elapsed "$elapsed"
|
|
}
|
|
}
|
|
|
|
|
|
main() {
|
|
main() {
|