PostgreSQL 最佳实践 - 块级增量备份(ZFS篇)单个数据库采用多个zfs卷(如表空间)时如何一致性备份

6 minute read

背景

当我们使用了多个ZFS卷或者文件系统时,如果一个实例的多个部分,如表空间,放在了不同的zfs上,再使用基于ZFS快照的备份时,可能出现多个文件系统不一致的情况。

例如控制文件是新的,但是数据是旧的。

保物理备份的一致性检查

基于文件的物理备份,为了保证备份的一致性,在备份开始时,需要做一个检查点,同时打开FULL PAGE WRTIE,同时还会生成backup_label文件记录备份开始时的WAL文件,检查点位置等信息。

backup_label文件内容示例

START WAL LOCATION: 42/EB000060 (file 0000000100000042000000EB)      
CHECKPOINT LOCATION: 42/EB000098      
BACKUP METHOD: pg_start_backup      
BACKUP FROM: master      
START TIME: 2016-08-23 19:43:32 CST      
LABEL: a      

同时backup_label也指出了当前备份是从主节点还是从 standby备份的

使用read_backup_label解析backup_label文件

优先从backup_label中得到备份开始的WAL位置,检查点的WAL位置,进行恢复。

而不是控制文件的信息,因为控制文件可能在备份过程中,经过检查点后,发生了变化。

/*      
 * read_backup_label: check to see if a backup_label file is present      
 *      
 * If we see a backup_label during recovery, we assume that we are recovering      
 * from a backup dump file, and we therefore roll forward from the checkpoint      
 * identified by the label file, NOT what pg_control says.  This avoids the      
 * problem that pg_control might have been archived one or more checkpoints      
 * later than the start of the dump, and so if we rely on it as the start      
 * point, we will fail to restore a consistent database state.      
 *      
 * Returns TRUE if a backup_label was found (and fills the checkpoint      
 * location and its REDO location into *checkPointLoc and RedoStartLSN,      
 * respectively); returns FALSE if not. If this backup_label came from a      
 * streamed backup, *backupEndRequired is set to TRUE. If this backup_label      
 * was created during recovery, *backupFromStandby is set to TRUE.      
 */      
static bool      
read_backup_label(XLogRecPtr *checkPointLoc, bool *backupEndRequired,      
                                  bool *backupFromStandby)      
{      
        char            startxlogfilename[MAXFNAMELEN];      
        TimeLineID      tli;      
        FILE       *lfp;      
        char            ch;      
        char            backuptype[20];      
        char            backupfrom[20];      
        uint32          hi,      
                                lo;      
      
        *backupEndRequired = false;      
        *backupFromStandby = false;      
      
        /*      
         * See if label file is present      
         */      
        lfp = AllocateFile(BACKUP_LABEL_FILE, "r");      
        if (!lfp)      
        {      
                if (errno != ENOENT)      
                        ereport(FATAL,      
                                        (errcode_for_file_access(),      
                                         errmsg("could not read file \"%s\": %m",      
                                                        BACKUP_LABEL_FILE)));      
                return false;                   /* it's not there, all is fine */      
        }      
      
        /*      
         * Read and parse the START WAL LOCATION and CHECKPOINT lines (this code      
         * is pretty crude, but we are not expecting any variability in the file      
         * format).      
         */      
        if (fscanf(lfp, "START WAL LOCATION: %X/%X (file %08X%16s)%c",      
                           &hi, &lo, &tli, startxlogfilename, &ch) != 5 || ch != '\n')      
                ereport(FATAL,      
                                (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),      
                                 errmsg("invalid data in file \"%s\"", BACKUP_LABEL_FILE)));      
        RedoStartLSN = ((uint64) hi) << 32 | lo;      
        if (fscanf(lfp, "CHECKPOINT LOCATION: %X/%X%c",      
                           &hi, &lo, &ch) != 3 || ch != '\n')      
                ereport(FATAL,      
                                (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),      
                                 errmsg("invalid data in file \"%s\"", BACKUP_LABEL_FILE)));      
        *checkPointLoc = ((uint64) hi) << 32 | lo;      
      
        /*      
         * BACKUP METHOD and BACKUP FROM lines are new in 9.2. We can't restore      
         * from an older backup anyway, but since the information on it is not      
         * strictly required, don't error out if it's missing for some reason.      
         */      
        if (fscanf(lfp, "BACKUP METHOD: %19s\n", backuptype) == 1)      
        {      
                if (strcmp(backuptype, "streamed") == 0)      
                        *backupEndRequired = true;      
        }      
      
        if (fscanf(lfp, "BACKUP FROM: %19s\n", backupfrom) == 1)      
        {      
                if (strcmp(backupfrom, "standby") == 0)      
                        *backupFromStandby = true;      
        }      
      
        if (ferror(lfp) || FreeFile(lfp))      
                ereport(FATAL,      
                                (errcode_for_file_access(),      
                                 errmsg("could not read file \"%s\": %m",      
                                                BACKUP_LABEL_FILE)));      
      
        return true;      
}      

两种物理备份模式

物理备份分exclusive和non-exclusive两种模式。

 * There are two kind of backups: exclusive and non-exclusive. An exclusive      
 * backup is started with pg_start_backup(), and there can be only one active      
 * at a time. The backup and tablespace map files of an exclusive backup are      
 * written to $PGDATA/backup_label and $PGDATA/tablespace_map, and they are      
 * removed by pg_stop_backup().      
 *      
 * A non-exclusive backup is used for the streaming base backups (see      
 * src/backend/replication/basebackup.c). The difference to exclusive backups      
 * is that the backup label and tablespace map files are not written to disk.      
 * Instead, their would-be contents are returned in *labelfile and *tblspcmapfile,      
 * and the caller is responsible for including them in the backup archive as      
 * 'backup_label' and 'tablespace_map'. There can be many non-exclusive backups      
 * active at the same time, and they don't conflict with an exclusive backup      
 * either.      
 *      
 * tblspcmapfile is required mainly for tar format in windows as native windows      
 * utilities are not able to create symlinks while extracting files from tar.      
 * However for consistency, the same is used for all platforms.      
 *      
 * needtblspcmapfile is true for the cases (exclusive backup and for      
 * non-exclusive backup only when tar format is used for taking backup)      
 * when backup needs to generate tablespace_map file, it is used to      
 * embed escape character before newline character in tablespace path.      
 *      
 * Returns the minimum WAL position that must be present to restore from this      
 * backup, and the corresponding timeline ID in *starttli_p.      
 *      
 * Every successfully started non-exclusive backup must be stopped by calling      
 * do_pg_stop_backup() or do_pg_abort_backup().      
 *      
 * It is the responsibility of the caller of this function to verify the      
 * permissions of the calling user!      

exclusive模式是使用pg_statrt_backup()函数调用产生的,这个函数只能在主节点调用

在备节点调用报错如下

XLogRecPtr      
do_pg_start_backup(const char *backupidstr, bool fast, TimeLineID *starttli_p,      
                                   char **labelfile, DIR *tblspcdir, List **tablespaces,      
                                   char **tblspcmapfile, bool infotbssize,      
                                   bool needtblspcmapfile)      
{      
        bool            exclusive = (labelfile == NULL);      
...      
	/*      
         * Currently only non-exclusive backup can be taken during recovery.      
         */      
        if (backup_started_in_recovery && exclusive)      
                ereport(ERROR,      
                                (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),      
                                 errmsg("recovery is in progress"),      
                                 errhint("WAL control functions cannot be executed during recovery.")));      

在standby备份如何保证输出backup_label

在standby备份,不能通过直接调用pg_start_backup()函数来生成backup_label文件,但是PG提供了pg_basebackup命令,是以non-exclusive的模式进行备份的。

labelfile非空,所以不会触发以上告警。

        startptr = do_pg_start_backup(opt->label, opt->fastcheckpoint, &starttli,      
                                                                  &labelfile, tblspcdir, &tablespaces,      
                                                                  &tblspc_map_file,      
                                                                  opt->progress, opt->sendtblspcmapfile);      

这个labelfile是在最开始的时候备份的,最后备份控制文件。

                        if (ti->path == NULL)      
                        {      
                                struct stat statbuf;      
      
                                /* In the main tar, include the backup_label first... */      
                                sendFileWithContent(BACKUP_LABEL_FILE, labelfile);      
      
                                /*      
                                 * Send tablespace_map file if required and then the bulk of      
                                 * the files.      
                                 */      
                                if (tblspc_map_file && opt->sendtblspcmapfile)      
                                {      
                                        sendFileWithContent(TABLESPACE_MAP, tblspc_map_file);      
                                        sendDir(".", 1, false, tablespaces, false);      
                                }      
                                else      
                                        sendDir(".", 1, false, tablespaces, true);      
      
                                /* ... and pg_control after everything else. */      
                                if (lstat(XLOG_CONTROL_FILE, &statbuf) != 0)      
                                        ereport(ERROR,      
                                                        (errcode_for_file_access(),      
                                                         errmsg("could not stat control file \"%s\": %m",      
                                                                        XLOG_CONTROL_FILE)));      
                                sendFile(XLOG_CONTROL_FILE, XLOG_CONTROL_FILE, &statbuf, false);      
                        }      
                        else      
                                sendTablespace(ti->path, false);      

通过以上方法,我们备份时的检查点信息得以保存在backup_label中,因此pg_basebackup的备份集,在恢复时可以拿到正确的WAL位置进行恢复,而不需要用到控制文件的检查点位置。

因为控制文件可能不是最初的位置。

zfs快照, 如何保证多个zfs文件系统的一致性

其实从pg_basebackup的备份步骤我们就能得知,备份集需要一个最老的检查点位置。

那我们不使用pg_basebackup,如何能保证在整个备份过程中控制文件是最老的呢?

因此最靠谱的方法是,优先给控制文件所在的ZFS打快照,然后再给其他ZFS文件系统打快照,这样就很好的解决了需要最老的控制文件的这个问题。

例子

回到我写的《PostgreSQL 最佳实践 - 块级增量备份(ZFS篇)方案与实战》

https://yq.aliyun.com/articles/59363

以上案例中一个standby集群用的是一个ZFS(所有表空间, 以及$PGDATA), 当数据库集群使用多个ZFS时, 因为快照只能基于单个volume或filesystem产生, 所以当我们使用了多个zfs filesystem是要得到数据库一致的备份, 怎么办呢?

例如 :

1. $PGDATA使用文件系统 zfs/pg_root

2. tbs1使用文件系统 zfs/tbs1

3. tbs2使用文件系统 zfs/tbs2

4. pg_xlog使用文件系统 zfs/pg_xlog

要使用zfs snapshot来备份这个PostgreSQL, 应该怎么做?

前面已经从代码中分析了,我们需要最老的控制文件即可。

首选创建控制文件所在zfs的快照, 再创建其他文件系统的快照.

pg_xlog的快照可以不创建, 而通过归档来恢复.

那么就比较清晰了, 以上快照的步骤如下 :

STIME=`date +%F%T`      
1. zfs snapshot zp1/pg_root@$STIME      
2. zfs snapshot zp1/tbs1@$STIME      
3. zfs snapshot zp1/tbs2@$STIME      

验证

验证一下这种方法的有效性

还记得我以前写过一篇使用老的控制文件来恢复一个异常的standby吗?

某数据库的流复制standby因为主库产生的XLOG过多, 延迟后触发了recovery.conf的restore命令, 但是restore里面用了sudo 进行copy并未保持源文件的owner, 属性等特征, 使用了root owner, 导致COPY完的xlog不能被postgresql 正常读取.

同事在处理这个事情, 因为没有了解实际情况, 上去就使用了pg_resetxlog修改standby的nextXID(resetxlog在这个场景属于扯淡的操作, 千万不要这么干), 接着大家知道的, standby无法正常完成standby的工作了.

这个数据库有10几个T, 要重新做standby的话, 拷贝的数据量太大了, 即使使用rsync重做, 工作量也比较大(表空间过多, 目录过多).

有没有省事的方法呢?

首先来分析一下事件,

1\. xlog不能被postgresql 正常读取(这个很好修复, 修改一下restore command就可以了, 或者不要用sudo 来拷贝).    
2014-11-30 10:05:54.505 CST,,,3695,,5435f48b.e6f,6,,2014-10-09 10:35:55 CST,1/0,0,LOG,00000,"restored log file ""0000000300002A9D0000004D"" from archive",,,,,,,,"RestoreArchivedFile, xlogarchive.c:254",""    
2014-11-30 10:05:54.534 CST,,,3695,,5435f48b.e6f,7,,2014-10-09 10:35:55 CST,1/0,0,PANIC,42501,"could not open file ""pg_xlog/0000000300002A9D0000004D"": Permission denied",,,,,,,,"XLogFileRead, xlog.c:2696","" ```  
    
    2\. pg_resetxlog对控制文件造成了持久性伤害, 没有办法修复.    
  
 pg_resetxlog -x 90010254 -f $PGDATA     ```  
  
为了快速恢复, 可以找到更早的控制文件, 刚好这套数据库的备份系统使用的是ZFS快照做的, 每天会创建一个快照, 所以可以取早些时间的快照, 拿到控制文件, 替换掉standby被人为"破坏"的控制文件, 启动standby后, 将从控制文件开始恢复需要的xlog. (只要这些xlog归档还在就可以了).    

操作过程 :     

1\. shutdown standby    

2\. mount zfs snapshot old then standby crashed time.    

3\. copy $PGDATA/global/pg_control from snapshot to standby.    
    
4\. startup standby.    
    
5\. umount snapshot.    
    
注意, 拿到的控制文件必须是standby crash之前的控制文件, 并且控制文件至今的所有xlog归档必须都在. postgresql standby将从控制文件需要的xlog开始恢复数据块. 所以这么做是完全可以的.    
    
现在standby数据库已经完全恢复了    
  882 postgres  20   0 2337m  15m  14m S  0.0  0.1   0:00.10 /opt/pgsql9.3.2/bin/postgres                                               
  883 postgres  20   0  157m 1072  476 S  0.0  0.0   0:00.14 postgres: logger process                                                   
  884 postgres  20   0 2338m 2.0g 2.0g S  0.0  8.6   5:16.35 postgres: startup process   recovering 0000000300002AA50000003F            
  889 postgres  20   0 2338m 2.0g 2.0g S  0.0  8.6   0:35.69 postgres: checkpointer process                                             
  890 postgres  20   0 2338m 2.0g 2.0g S  0.0  8.6   0:34.98 postgres: writer process                                                   
  905 postgres  20   0  159m 1212  456 S  0.0  0.0   0:02.62 postgres: stats collector process                                          
 1922 postgres  20   0  105m 1632 1180 S  0.0  0.0   0:00.01 -bash                                                                      
 1959 postgres  20   0  137m 1764 1292 S  0.0  0.0   0:00.00 psql                                                                       
 1960 postgres  20   0 2340m 6780 4684 S  0.0  0.0   0:00.01 postgres: postgres postgres [local] idle                                   
 4309 postgres  20   0 2346m 7080 1748 S  0.0  0.0   0:00.67 postgres: wal receiver process   streaming 2AA5/3F0429C0     

Flag Counter

digoal’s 大量PostgreSQL文章入口