PG集群实现自动切换(非repmgrd模式）

灰太狼 2023-06-30 05:26 3阅读 0赞

\#!/bin/bash

whichday=\`date "+%w"\`  
v\_param=$\#

\#判断参数个数  
if \[ $v\_param -ge 3 \];then  
        echo "Invalid argument!! E.g sh pg-cluster-switchover.sh 'paas|bi' vlnx191001.xxx.cn (pg-slave-node)"  
        exit 1  
fi

v\_wthich\_type=$1  
v\_slave\_hostname=$2  
v\_valid=''  
v\_short\_hostname=''  
v\_short\_hostname=\`echo $v\_slave\_hostname | awk -F '.' '\{print $1\}'\`  
v\_p\_s=''  
v\_p\_s=\`echo $v\_slave\_hostname | awk -F '0' '\{print $2\}'\`

echo Server: $v\_slave\_hostname

v\_primary\_hostname=''  
        v\_version=''  
        log\_path=''

\#获取Postgres服务版本  
        v\_version\_str=\`psql -h$v\_slave\_hostname -Uzhaowz -d postgres -c "select version()" |grep "PostgreSQL 9"\`

if \[ -n "$v\_version\_str" \];then  
                v\_version=9.6  
                log\_path=pg\_log  
        fi

if \[ -z "$v\_version" \];then  
               v\_version\_str=\`psql -h$v\_slave\_hostname -Uzhaowz -d postgres -c "select version()" |grep "PostgreSQL 10"\`  
                if \[ -n "$v\_version\_str" \];then  
                        v\_version=10  
                        log\_path=log  
                fi  
        fi

\#校验服务器域名地址和业务机器类别是否正确  
        if \[ "$\{v\_wthich\_type\}" == 'paas' \];then  
                if \[ "$\{v\_version\}" == '9.6' \];then  
                        v\_valid=\`ssh $v\_slave\_hostname /usr/pgsql-$v\_version/bin/repmgr -f /etc/repmgr/$v\_version/repmgr.conf cluster show | grep master | grep $v\_short\_hostname\`  
                elif \[ "$\{v\_version\}" == '10' \];then  
                        v\_valid=\`ssh $v\_slave\_hostname /usr/pgsql-$v\_version/bin/repmgr -f /etc/repmgr/$v\_version/repmgr.conf cluster show | grep primary | grep $v\_short\_hostname\`  
                fi

if \[ -n "$v\_valid" \];then  
                                echo "Invalid server $v\_slave\_hostname"  
                                exit 1  
                        else  
                                if \[ "$\{v\_p\_s\}" == '191' \];then  
                                        v\_primary\_hostname=\`echo $v\_slave\_hostname | sed 's/vlnx191/vlnx192/g'\`  
                                elif \[ "$\{v\_p\_s\}" == '192' \];then  
                                        v\_primary\_hostname=\`echo $v\_slave\_hostname | sed 's/vlnx192/vlnx191/g'\`  
                                else  
                                        echo "Business machine category error!"  
                                        exit 1  
                                fi  
                        fi  
        elif \[ "$\{v\_wthich\_type\}" == 'bi' \];then  
                if \[ "$\{v\_version\}" == '9.6' \];then  
                        v\_valid=\`ssh $v\_slave\_hostname /usr/pgsql-$v\_version/bin/repmgr -f /etc/repmgr/$v\_version/repmgr.conf cluster show | grep master | grep $v\_short\_hostname\`  
                elif \[ "$\{v\_version\}" == '10' \];then  
                        v\_valid=\`ssh $v\_slave\_hostname /usr/pgsql-$v\_version/bin/repmgr -f /etc/repmgr/$v\_version/repmgr.conf cluster show | grep primary | grep $v\_short\_hostname\`  
                fi

if \[ -n "$v\_valid" \];then  
                                echo "Invalid server $v\_slave\_hostname"  
                                exit 1  
                        else  
                                if \[ "$\{v\_p\_s\}" == '193' \];then  
                                        v\_primary\_hostname=\`echo $v\_slave\_hostname | sed 's/vlnx193/vlnx194/g'\`  
                                elif \[ "$\{v\_p\_s\}" == '194' \];then  
                                        v\_primary\_hostname=\`echo $v\_slave\_hostname | sed 's/vlnx194/vlnx193/g'\`  
                                else  
                                        echo "Business machine category error!"  
                                        exit 1  
                                fi

fi  
        else  
                echo "Business machine category error!"  
                exit 1  
        fi

\#获取当前周几  
        if \[ "$\{whichday\}" == '1' \];then  
                filename=postgresql-Mon.log  
        elif \[ "$\{whichday\}" == '2' \];then  
                filename=postgresql-Tue.log  
        elif \[ "$\{whichday\}" == '3' \];then  
                filename=postgresql-Wed.log  
        elif \[ "$\{whichday\}" == '4' \];then  
                filename=postgresql-Thu.log  
        elif \[ "$\{whichday\}" == '5' \];then  
                filename=postgresql-Fri.log  
        elif \[ "$\{whichday\}" == '6' \];then  
                filename=postgresql-Sat.log  
        elif \[ "$\{whichday\}" == '0' \];then  
                filename=postgresql-Sun.log  
        fi

\#Switchover  
        v\_switchover\_succ=''  
        pv\_vip=''  
        if \[ "$\{v\_version\}" == '10' \];then  
                ssh $v\_slave\_hostname " sudo su - postgres -c 'cat /dev/null > /var/log/repmgr/repmgr.log'"  
                ssh $v\_primary\_hostname " sudo su - postgres -c 'cat /dev/null > /var/log/repmgr/repmgr.log'"

pv\_vip=\`ssh $v\_primary\_hostname sudo ifconfig eth3 | grep inet | awk '\{print $2\}' | cut -d':' -f2\`

ssh $v\_slave\_hostname "sudo su - postgres -c '/usr/pgsql-10/bin/repmgr -t --log-to-file -f /etc/repmgr/10/repmgr.conf standby switchover'"  
                v\_switchover\_succ=\`ssh $v\_slave\_hostname sudo cat /var/log/repmgr/repmgr.log | grep 'STANDBY SWITCHOVER has completed successfully'\`  
                ssh $v\_slave\_hostname /usr/pgsql-10/bin/repmgr -f /etc/repmgr/10/repmgr.conf cluster show

elif \[ "$\{v\_version\}" == '9.6' \];then  
                ssh $v\_slave\_hostname " sudo su - postgres -c 'cat /dev/null > /var/log/repmgr/repmgr-9.6.log'"  
                ssh $v\_primary\_hostname " sudo su - postgres -c 'cat /dev/null > /var/log/repmgr/repmgr-9.6.log'"

pv\_vip=\`ssh $v\_primary\_hostname sudo ifconfig eth3 | grep inet | awk '\{print $2\}' | cut -d':' -f2\`

ssh $v\_slave\_hostname "sudo su - postgres -c '/usr/pgsql-9.6/bin/repmgr -t --log-to-file -f /etc/repmgr/9.6/repmgr.conf standby switchover'"  
                v\_switchover\_succ=\`ssh $v\_slave\_hostname sudo cat /var/log/repmgr/repmgr-9.6.log | grep 'switchover was successful'\`  
                ssh $v\_slave\_hostname /usr/pgsql-9.6/bin/repmgr -f /etc/repmgr/9.6/repmgr.conf cluster show  
        fi

if \[ -z "$v\_switchover\_succ" \];then  
                if \[ "$\{v\_version\}" == '10' \];then  
                        echo \`ssh $v\_slave\_hostname sudo cat /var/log/repmgr/repmgr.log \`  
                elif \[ "$\{v\_version\}" == '9.6' \];then  
                        echo \`ssh $v\_slave\_hostname sudo cat /var/log/repmgr/repmgr-9.6.log\`  
                fi  
                exit  
        fi

if \[ -n "$v\_switchover\_succ" \];then  
                v\_true\_false=''  
                sv\_vip=''  
                s\_vip=''  
                v\_networkmanager=''  
                v\_ethx=''

pv\_device=''  
                sv\_device=''  
                pv\_device=\`ssh $v\_primary\_hostname sudo nmcli connection show  'Wired\\ connection\\ 3' | grep 'connection.interface-name:' | awk '\{print $2\}'\`  
                sv\_device=\`ssh $v\_slave\_hostname sudo nmcli connection show  'Wired\\ connection\\ 3' | grep 'connection.interface-name:' | awk '\{print $2\}'\`  
                if \[ "$\{pv\_device\}" != 'eth3' \];then  
                        pv\_device=\`ssh $v\_primary\_hostname sudo nmcli connection show  'Wired\\ connection\\ 3' | grep 'DEVICES:' | awk '\{print $2\}'\`  
                                if \[ "$\{pv\_device\}" != 'eth3' \];then  
                                        pv\_device='eth3'  
                                fi  
                fi

if \[ "$\{sv\_device\}" != 'eth3' \];then  
                        sv\_device=\`ssh $v\_slave\_hostname sudo nmcli connection show  'Wired\\ connection\\ 3' | grep 'DEVICES:' | awk '\{print $2\}'\`  
                                if \[ "$\{sv\_device\}" != 'eth3' \];then  
                                        sv\_device='eth3'  
                                fi  
                fi

pv\_device\_name='Wired\\ connection\\ 3'  
                sv\_device\_name='Wired\\ connection\\ 3'  
                p\_dev\_name='Wired connection 3'  
                s\_dev\_name='Wired connection 3'

\#主库禁止eth3自动激活,关闭VIP             
                if \[ -n "$pv\_device" \];then  
                        ssh $v\_primary\_hostname "sudo nmcli connection modify '$p\_dev\_name' connection.autoconnect no"

v\_true\_false=\`ssh $v\_primary\_hostname sudo nmcli con show 'Wired\\ connection\\ 3' |grep 'connection.autoconnect:' | grep no\`  
                        echo 1234

if \[ -n "$v\_true\_false" \];then  
                                echo 9999  
                                ssh $v\_primary\_hostname "sudo nmcli connection down '$p\_dev\_name'"  
                        fi

\#从库激活VIP（临时）  
                if \[ -n "$sv\_device" \];then  
                        ssh $v\_slave\_hostname "sudo nmcli connection modify '$s\_dev\_name' connection.autoconnect yes"  
                        sv\_vip=\`ssh $v\_slave\_hostname sudo nmcli con show  'Wired\\ connection\\ 3' | grep 'ipv4.addresses:' | awk '\{print $2\}'\`  
                        s\_vip=\`ssh $v\_slave\_hostname sudo nmcli con show  'Wired\\ connection\\ 3' | grep 'ipv4.addresses:' | awk '\{print $2\}' | awk -F '/' '\{print $1\}'\`

ssh $v\_slave\_hostname "sudo nmcli connection up '$s\_dev\_name'"  
                        echo 2345

v\_ethx=\`ssh $v\_slave\_hostname sudo ifconfig | grep $sv\_device | awk -F ':' '\{print $1\}'\`

if \[ -n "$v\_ethx" \];then  
                                echo 3456  
                                        ssh $v\_slave\_hostname "sudo nmcli connection modify '$s\_dev\_name' ipv4.addresses $sv\_vip  ipv4.method manual"  
                        else  
                                if \[ -n "$s\_vip" \];then  
                                echo 4567  
                                        ssh $v\_slave\_hostname sudo ifconfig $sv\_device up  
                                        ssh $v\_slave\_hostname sudo ifconfig $sv\_device  $s\_vip  netmask 255.255.0.0 up  
                                else  
                                echo 5678         
                                        ssh $v\_slave\_hostname sudo ifconfig $sv\_device up  
                                        ssh $v\_slave\_hostname sudo ifconfig $sv\_device  $pv\_vip  netmask 255.255.0.0 up  
                                fi  
                        fi

v\_networkmanager=\`ssh $v\_slave\_hostname sudo systemctl status NetworkManager |grep 'Active: active (running)'\`  
                        if \[ -z "$v\_networkmanager" \];then  
                                ssh $v\_slave\_hostname sudo systemctl start NetworkManager  
                        fi  
                fi  
        fi