OGG_HOME=/GoldenGate/app
LOG_FILE=/GoldenGate/app/logs/monitor.log
ALERT_EMAIL=”itpux@fgedu.net.cn”

check_process_status() {
local process_name=$1
local status=$(echo “INFO $process_name” | $OGG_HOME/ggsci 2>/dev/null | grep “Status” | awk ‘{print $2}’)
echo $status
}

check_process_lag() {
local process_name=$1
local lag=$(echo “LAG $process_name” | $OGG_HOME/ggsci 2>/dev/null | grep “Lag” | awk ‘{print $2}’)
echo $lag
}

echo “========== OGG监控检查: $(date) ==========” >> $LOG_FILE

# 检查所有Extract进程
for extract in E_FGEDU01 E_FGEDU02; do
status=$(check_process_status “EXTRACT $extract”)
lag=$(check_process_lag “EXTRACT $extract”)
echo “Extract $extract: Status=$status, Lag=$lag” >> $LOG_FILE

if [ “$status” != “RUNNING” ]; then
echo “警告: Extract $extract 未运行，尝试启动…” >> $LOG_FILE
echo “START EXTRACT $extract” | $OGG_HOME/ggsci >> $LOG_FILE 2>&1
fi
done

# 检查所有Replicat进程
for replicat in R_FGEDU01 R_FGEDU02; do
status=$(check_process_status “REPLICAT $replicat”)
lag=$(check_process_lag “REPLICAT $replicat”)
echo “Replicat $replicat: Status=$status, Lag=$lag” >> $LOG_FILE

if [ “$status” != “RUNNING” ]; then
echo “警告: Replicat $replicat 未运行，尝试启动…” >> $LOG_FILE
echo “START REPLICAT $replicat” | $OGG_HOME/ggsci >> $LOG_FILE 2>&1
fi
done

echo “监控检查完成” >> $LOG_FILE