|
@@ -59,7 +59,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 ${sh_path}/ad_monitor_util.py --level error --msg "$msg" --start "$start_time" --elapsed "$elapsed"
|
|
|
|
|
|
+ # /root/anaconda3/bin/python ${sh_path}/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"
|
|
@@ -137,7 +137,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_early_1}"
|
|
local msg="大数据数据生产校验失败, 分区: ${today_early_1}"
|
|
echo -e "$LOG_PREFIX -- 大数据数据生产校验 -- ${msg}: 耗时 $elapsed"
|
|
echo -e "$LOG_PREFIX -- 大数据数据生产校验 -- ${msg}: 耗时 $elapsed"
|
|
- /root/anaconda3/bin/python ${sh_path}/ad_monitor_util.py --level error --msg "$msg" --start "$start_time" --elapsed "$elapsed"
|
|
|
|
|
|
+ # /root/anaconda3/bin/python ${sh_path}/ad_monitor_util.py --level error --msg "$msg" --start "$start_time" --elapsed "$elapsed"
|
|
exit 1
|
|
exit 1
|
|
fi
|
|
fi
|
|
done
|
|
done
|