1. 前言
MongoDB复制集通过oplog进行同步，但是4.4之前oplog只能通过参数设置固定大小，无法像mysql binlog那样指定保留天数。
这种做法有很多问题：
- 主库峰值写入太多导致从库延迟，对应的oplog尚未传输到从库便被覆盖，这种情况下会导致从库重建；
- mongo实例执行PITR恢复，因为没有对应时间段的oplog导致无法完成。
MongoDB官方应该是意识到这个问题，4.4引入oplogMinRetentionHours
New in version 4.4: Specifies the minimum number of hours to preserve an oplog entry,where the decimal values represent the fractions of an hour. For example, avalue of 1.5 represents one hour and thirty minutes.
对于pre-4.4版本，如何归档线上的oplog并保证没有丢失，成为1个问题。
2. 脚本逻辑
我写了一个小脚本，每隔5分钟执行1次，用于备份MongoDB实例的oplog，脚本逻辑如下：
1 检测是否存在last_oplog_ts文件
- 如果文件不存在则创建，并写入rs.printReplicationInfo()返回的oplog last event time，然后执行第3步
- 文件存在但是为空，退出并发出告警
- 文件存在不为空，读取文件内容并进行下一步
2 当前实例oplog的first event时间戳
执行命令，获取当前实例oplog的first event时间戳：
代码语言：javascript复制shard1:SECONDARY> rs.printReplicationInfo()
configured oplog size: 10240MB
log length start to end: 1248136secs(346.7hrs)
oplog first event time: Wed Jul 14 2021 23:19:25 GMT 0800 (CST)
oplog last event time: Thu Jul 29 2021 10:01:41 GMT 0800 (CST)
now: Thu Jul 29 2021 10:01:41GMT 0800 (CST)
[root@ssg3-db-mongodb-02 ~]# mongo -u*** -p"***"--authenticationDatabase admin --eval "rs.printReplicationInfo()" |grep 'oplog first event' | cut -d' ' -f7,8,9,10,11,12
Jul 14 2021 23:19:25 GMT 0800 (CST)将当前获取的first event time和第一步获取的last event time进行差值比较，如果差值小于阈值(默认1200s，可调整)，则执行如下步骤：
获取rs.printReplicationInfo()返回的oplog last event time，将其更新到last_oplog_ts
执行第3步。
3 执行oplog备份
如果第一次mongodump执行失败，间隔60s后再次尝试，如果还失败则退出
对备份出的oplog目录进行打包压缩。
4 删除7天之前的oplog压缩文件
注：上述的rs.printReplicationInfo()命令可以分别用db.getReplicationInfo().tFirst和db.getReplicationInfo().tLast替换
整个脚本的逻辑比较简单，借助1个磁盘临时文件存储oplog last event time。
每次执行脚本都会用当前的oplog first event time和其进行比较，这个差值t1可以粗略看做oplog的"可用容量"：即按照当前oplog生成速度，上次oplog备份后生成的oplog，将在t1秒后会被覆盖。
如果t1小于阈值，则更新临时文件并执行1次oplog备份。
oplog本身是幂等的，每个备份文件的时间段即便有重叠，在重放的时候也能保证数据完整。
3. 脚本完整内容
以下是脚本全部内容，可根据实际情况进行修改。
代码语言：javascript复制#!/bin/bash
source ~/.bash_profile
BASE_DIR=/data/backup
MONGO=/usr/local/mongodb/bin/mongo
MONGO_DUMP=/usr/local/mongodb/bin/mongodump
MONGO_PORT=27017
MONGO_HOST=127.0.0.1
LOG=oplog_backup.log
OPLOG_TS_FILE=last_oplog_ts
CUR_TIME=`date`
DB_IP=`/sbin/ip a | grep eth0 | grep inet |awk '{print $2}' | cut -d'/' -f1 | head -1`
BACKUP_TIME=`date %Y%m%d%H%M`
DB_BACKUP_NAME=oplog_${DB_IP}_${BACKUP_TIME}.tar.gz
BACKUP_TMP_DIR=${BACKUP_TIME}
THRESHOLD=1200
KEEP_DAY=7
do_exit(){
if[ $? -eq 0 ]; then
exit 0
else
#根据各自环境的实际监控逻辑自行实现
exit 1
fi
}
oplog_backup(){
$MONGO_DUMP -h $MONGO_HOST:$MONGO_PORT -u backup -p *******--authenticationDatabase "admin" -d local -c oplog.rs --gzip -o $BACKUP_TMP_DIR
if[ $? -ne 0 ]; then
rm -rf $BACKUP_TMP_DIR
sleep 60
$MONGO_DUMP -h $MONGO_HOST:$MONGO_PORT -u backup -p *******--authenticationDatabase "admin" -d local -c oplog.rs --gzip -o $BACKUP_TMP_DIR
do_exit
fi
tar-zcvf $DB_BACKUP_NAME $BACKUP_TMP_DIR
do_exit
rm-rf $BACKUP_TMP_DIR
}
if [ ! -d "$BASE_DIR" ]; then
mkdir "$BASE_DIR"
fi
cd $BASE_DIR
#last_oplog_ts not exists, create it andtake an oplog backup
if [ ! -f "$OPLOG_TS_FILE" ];then
$MONGO -u backup -p ******* --authenticationDatabase admin --port"$MONGO_PORT" --eval "rs.printReplicationInfo()" | grep'oplog last event' | cut -d' ' -f7,8,9,10,11,12 > $OPLOG_TS_FILE
do_exit
echo "`date ` $OPLOG_TS_FILE not exists, initiate it and take anoplog backup" >> $LOG
oplog_backup
echo "`date` oplog backup succeed" >> $LOG
exit 0
fi
LAST_EVENT=$(cat $OPLOG_TS_FILE)
#last_oplog_ts is empty and has nolast_event, the oplog backup fails and exits
if [ ! -n "$LAST_EVENT" ];then
echo 1 > /data/backup/dumperr.log
echo "`date` LAST_EVENT in $OPLOG_TS_FILE is NULL and oplog backupfails" >> $LOG
exit 1
fi
#caculate the diff in seconds, and take anoplog backup when it's lower than the threshold
FIRST_EVENT=`$MONGO -u backup -p *******--authenticationDatabase admin --port "$MONGO_PORT" --eval"rs.printReplicationInfo()" | grep 'oplog first event' | cut -d' '-f7,8,9,10,11,12`
E1=$(date ' %s' -d"${LAST_EVENT}")
E2=$(date ' %s' -d"${FIRST_EVENT}")
DIFF=`expr $E1 - $E2`
echo "the time diff now is ${DIFF}sand the threshold is ${THRESHOLD}s"
if [ $DIFF -lt $THRESHOLD ]; then
echo "`date` the diff is lower than ${THRESHOLD}, take an oplogbackup" >> $LOG
$MONGO -u backup -p ******* --authenticationDatabase admin --port"$MONGO_PORT" --eval "rs.printReplicationInfo()" | grep'oplog last event' | cut -d' ' -f7,8,9,10,11,12 > $OPLOG_TS_FILE
do_exit
oplog_backup
echo "`date` oplog backup succeed" >> $LOG
fi
find $BASE_DIR -name"oplog_${DB_IP}*" -mtime ${KEEP_DAY} | xargs rm -rf作者：任坤
现居珠海，先后担任专职 Oracle 和 MySQL DBA，现在主要负责 MySQL、mongoDB 和 Redis 维护工作。
