OGG_HOME=/GoldenGate/app
METRICS_FILE=/tmp/ogg_metrics.prom

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

if [ “$status” = “RUNNING” ]; then
status_code=1
fi

echo “ogg_process_status{process=\”$process\”} $status_code” >> $METRICS_FILE
}

collect_process_lag() {
local process=$1
local lag=$(echo “LAG $process” | $OGG_HOME/ggsci 2>/dev/null | grep “Lag” | awk ‘{print $2}’)
local lag_seconds=$(echo $lag | awk -F: ‘{print $1*3600 + $2*60 + $3}’)

echo “ogg_process_lag{process=\”$process\”} $lag_seconds” >> $METRICS_FILE
}

# 清空指标文件
> $METRICS_FILE

# 采集所有进程指标
for process in E_FGEDU01 E_FGEDU02 R_FGEDU01 R_FGEDU02; do
collect_process_status $process
collect_process_lag $process
done

# 输出指标
cat $METRICS_FILE