Add backup manager tool

Makefile

@@ -45,6 +45,12 @@ discovery:
 admission-controller:
 	$(GO) -ldflags '$(LDFLAGS)' -o images/tidb-operator/bin/tidb-admission-controller cmd/admission-controller/main.go
 
+backup-manager:
+	$(GO) -ldflags '$(LDFLAGS)' -o images/backup-manager/bin/tidb-backup-manager cmd/backup-manager/main.go
+
+backup-docker: backup-manager
+	docker build --tag "${DOCKER_REGISTRY}/pingcap/tidb-backup-manager:latest" images/backup-manager
+
 e2e-setup:
 	# ginkgo doesn't work with retool for Go 1.11
 	@GO111MODULE=on CGO_ENABLED=0 go get github.com/onsi/ginkgo@v1.6.0

cmd/backup-manager/app/backup/backup.go

@@ -0,0 +1,224 @@
+// Copyright 2019 PingCAP, Inc.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package backup
+
+import (
+	"database/sql"
+	"fmt"
+	"io/ioutil"
+	"os/exec"
+	"path/filepath"
+	"strconv"
+	"strings"
+	"time"
+
+	"github.com/golang/glog"
+	"github.com/mholt/archiver"
+	"github.com/pingcap/tidb-operator/cmd/backup-manager/app/constants"
+	"github.com/pingcap/tidb-operator/cmd/backup-manager/app/util"
+)
+
+// BackupOpts contains the input arguments to the backup command
+type BackupOpts struct {
+	Namespace   string
+	TcName      string
+	TidbSvc     string
+	Password    string
+	User        string
+	StorageType string
+	BackupName  string
+}
+
+func (bo *BackupOpts) String() string {
+	return fmt.Sprintf("%s/%s", bo.Namespace, bo.TcName)
+}
+
+func (bo *BackupOpts) getBackupFullPath() string {
+	return filepath.Join(constants.BackupRootPath, bo.getBackupRelativePath())
+}
+
+func (bo *BackupOpts) getBackupRelativePath() string {
+	backupName := fmt.Sprintf("backup-%s", time.Now().UTC().Format(time.RFC3339))
+	return fmt.Sprintf("%s_%s/%s", bo.Namespace, bo.TcName, backupName)
+}
+
+func (bo *BackupOpts) getDestBucketURI() string {
+	return fmt.Sprint("%s://%s%s", bo.StorageType, bo.getBackupRelativePath(), constants.DefaultArchiveExtention)
+}
+
+func (bo *BackupOpts) getTikvGCLifeTime(db *sql.DB) (string, error) {
+	var tikvGCTime string
+	row := db.QueryRow("select variable_value from ? where variable_name= ?", constants.TidbMetaTable, constants.TikvGCVariable)
+	err := row.Scan(&tikvGCTime)
+	if err != nil {
+		return tikvGCTime, fmt.Errorf("query cluster %s %s failed, err: %v", bo, constants.TikvGCVariable, err)
+	}
+	return tikvGCTime, nil
+}
+
+func (bo *BackupOpts) setTikvGClifeTime(db *sql.DB, gcTime string) error {
+	_, err := db.Exec("update ? set variable_value = ? where variable_name = ?", constants.TidbMetaTable, gcTime, constants.TikvGCVariable)
+	if err != nil {
+		return fmt.Errorf("set cluster %s %s failed, err: %v", bo, constants.TikvGCVariable, err)
+	}
+	return nil
+}
+
+func (bo *BackupOpts) dumpTidbClusterData() (string, error) {
+	bfPath := bo.getBackupFullPath()
+	err := util.EnsureDirectoryExist(bfPath)
+	if err != nil {
+		return "", err
+	}
+	args := []string{
+		fmt.Sprintf("--outputdir=%s", bfPath),
+		fmt.Sprintf("--host=%s", bo.TidbSvc),
+		"--port=4000",
+		fmt.Sprintf("--User=%s", bo.User),
+		fmt.Sprintf("--Password=%s", bo.Password),
+		"--long-query-guard=3600",
+		"--tidb-force-priority=LOW_PRIORITY",
+		"--verbose=3",
+	}
+
+	dumper := exec.Command("/mydumper", args...)
+	if err := dumper.Start(); err != nil {
+		return bfPath, fmt.Errorf("cluster %s, start mydumper command %v falied, err: %v", bo, args, err)
+	}
+	if err := dumper.Wait(); err != nil {
+		return bfPath, fmt.Errorf("cluster %s, execute mydumper command %v failed, err: %v", bo, args, err)
+	}
+	return bfPath, nil
+}
+
+func (bo *BackupOpts) backupDataToRemote(source, bucketURI string) error {
+	destBucket := util.NormalizeBucketURI(bucketURI)
+	tmpDestBucket := fmt.Sprintf("%s.tmp", destBucket)
+	// TODO: We may need to use exec.CommandContext to control timeouts.
+	rcCopy := exec.Command("rclone", constants.RcloneConfigArg, "copyto", source, tmpDestBucket)
+	if err := rcCopy.Start(); err != nil {
+		return fmt.Errorf("cluster %s, start rclone copyto command for upload backup data %s falied, err: %v", bo, bucketURI, err)
+	}
+	if err := rcCopy.Wait(); err != nil {
+		return fmt.Errorf("cluster %s, execute rclone copyto command for upload backup data %s failed, err: %v", bo, bucketURI, err)
+	}
+
+	glog.Info("upload cluster %s backup data %s successfully, now move it to permanent URL", bo, bucketURI)
+
+	// the backup was a success
+	// remove .tmp extension
+	rcMove := exec.Command("rclone", constants.RcloneConfigArg, "moveto", tmpDestBucket, destBucket)
+
+	if err := rcMove.Start(); err != nil {
+		return fmt.Errorf("cluster %s, start rclone moveto command falied, err: %v", bo, err)
+	}
+
+	if err := rcMove.Wait(); err != nil {
+		return fmt.Errorf("cluster %s, execute rclone moveto command falied, err: %v", bo, err)
+	}
+	return nil
+}
+
+func (bo *BackupOpts) cleanRemoteBackupData(bucket string) error {
+	destBucket := util.NormalizeBucketURI(bucket)
+	rcDelete := exec.Command("rclone", constants.RcloneConfigArg, "deletefile", destBucket)
+	if err := rcDelete.Start(); err != nil {
+		return fmt.Errorf("cluster %s, start rclone deletefile command falied, err: %v", bo, err)
+	}
+	if err := rcDelete.Wait(); err != nil {
+		return fmt.Errorf("cluster %s, execute rclone deletefile command failed, err: %v", bo, err)
+	}
+
+	glog.Info("cluster %s backup %s was deleted successfully", bo, bucket)
+	return nil
+}
+
+func (bo *BackupOpts) getDSN(db string) string {
+	return fmt.Sprintf("%s:%s@(%s:4000)/%s?/charset=utf8", bo.User, bo.Password, bo.TidbSvc, db)
+}
+
+/*
+	getCommitTsFromMetadata get commitTs from mydumper's metadata file
+
+	metadata file format is as follows:
+
+		Started dump at: 2019-06-13 10:00:04
+		SHOW MASTER STATUS:
+			Log: tidb-binlog
+			Pos: 409054741514944513
+			GTID:
+
+		Finished dump at: 2019-06-13 10:00:04
+*/
+func getCommitTsFromMetadata(backupPath string) (string, error) {
+	var commitTs string
+
+	metaFile := filepath.Join(backupPath, constants.MetaDataFile)
+	if exist := util.IsFileExist(metaFile); !exist {
+		return commitTs, fmt.Errorf("file %s does not exist or is not regular file", metaFile)
+	}
+	contents, err := ioutil.ReadFile(metaFile)
+	if err != nil {
+		return commitTs, fmt.Errorf("read metadata file %s failed, err: %v", err)
+	}
+
+	for _, lineStr := range strings.Split(string(contents), "\n") {
+		if !strings.Contains(lineStr, "Pos") {
+			continue
+		}
+		lineStrSlice := strings.Split(lineStr, ":")
+		if len(lineStrSlice) != 2 {
+			return commitTs, fmt.Errorf("parse mydumper's metadata file %s failed, str: %s", metaFile, lineStr)
+		}
+		commitTs = strings.TrimSpace(lineStrSlice[1])
+		break
+	}
+	return commitTs, nil
+}
+
+// getBackupSize get the backup data size
+func getBackupSize(backupPath string) (int64, error) {
+	var size int64
+	if exist := util.IsFileExist(backupPath); !exist {
+		return size, fmt.Errorf("file %s does not exist or is not regular file", backupPath)
+	}
+	// Uses the same niceness level as cadvisor.fs does when running du
+	// Uses -B 1 to always scale to a blocksize of 1 byte
+	out, err := exec.Command("nice", "-n", "19", "du", "-s", "-B", "1", backupPath).CombinedOutput()
+	if err != nil {
+		return size, fmt.Errorf("failed to get backup %s size, err: %v", backupPath, err)
+	}
+	sizeStr := strings.Fields(string(out))[0]
+	size, err = strconv.ParseInt(sizeStr, 10, 64)
+	if err != nil {
+		return size, fmt.Errorf("failed to parse size string %s, err: %v", sizeStr, err)
+	}
+	return size, nil
+}
+
+// archiveBackupData archive backup data by destFile's extension name
+func archiveBackupData(backupDir, destFile string) error {
+	if exist := util.IsDirExist(backupDir); !exist {
+		return fmt.Errorf("dir %s does not exist or is not a dir", backupDir)
+	}
+	destDir := filepath.Dir(destFile)
+	if err := util.EnsureDirectoryExist(destDir); err != nil {
+		return err
+	}
+	err := archiver.Archive([]string{backupDir}, destFile)
+	if err != nil {
+		return fmt.Errorf("archive backup data %s to %s failed, err: %v", backupDir, destFile, err)
+	}
+	return nil
+}