97 lines
2.1 KiB
Go
97 lines
2.1 KiB
Go
package main
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"os"
|
|
"path/filepath"
|
|
|
|
"github.com/influxdata/influxdb/v2"
|
|
"github.com/influxdata/influxdb/v2/bolt"
|
|
"github.com/influxdata/influxdb/v2/http"
|
|
"github.com/spf13/cobra"
|
|
"go.uber.org/multierr"
|
|
)
|
|
|
|
func cmdBackup(f *globalFlags, opt genericCLIOpts) *cobra.Command {
|
|
cmd := opt.newCmd("backup", backupF, false)
|
|
cmd.Short = "Backup the data in InfluxDB"
|
|
cmd.Long = fmt.Sprintf(
|
|
`Backs up data and meta data for the running InfluxDB instance.
|
|
Downloaded files are written to the directory indicated by --path.
|
|
The target directory, and any parent directories, are created automatically.
|
|
Data file have extension .tsm; meta data is written to %s in the same directory.`,
|
|
bolt.DefaultFilename)
|
|
|
|
f.registerFlags(cmd)
|
|
|
|
opts := flagOpts{
|
|
{
|
|
DestP: &backupFlags.Path,
|
|
Flag: "path",
|
|
Short: 'p',
|
|
EnvVar: "PATH",
|
|
Desc: "directory path to write backup files to",
|
|
Required: true,
|
|
},
|
|
}
|
|
opts.mustRegister(cmd)
|
|
|
|
return cmd
|
|
}
|
|
|
|
var backupFlags struct {
|
|
Path string
|
|
}
|
|
|
|
func newBackupService() (influxdb.BackupService, error) {
|
|
return &http.BackupService{
|
|
Addr: flags.Host,
|
|
Token: flags.Token,
|
|
}, nil
|
|
}
|
|
|
|
func backupF(cmd *cobra.Command, args []string) error {
|
|
ctx := context.Background()
|
|
|
|
if backupFlags.Path == "" {
|
|
return fmt.Errorf("must specify path")
|
|
}
|
|
|
|
err := os.MkdirAll(backupFlags.Path, 0777)
|
|
if err != nil && !os.IsExist(err) {
|
|
return err
|
|
}
|
|
|
|
backupService, err := newBackupService()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
id, backupFilenames, err := backupService.CreateBackup(ctx)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
fmt.Printf("Backup ID %d contains %d files\n", id, len(backupFilenames))
|
|
|
|
for _, backupFilename := range backupFilenames {
|
|
dest := filepath.Join(backupFlags.Path, backupFilename)
|
|
w, err := os.OpenFile(dest, os.O_WRONLY|os.O_CREATE|os.O_TRUNC, 0666)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
err = backupService.FetchBackupFile(ctx, id, backupFilename, w)
|
|
if err != nil {
|
|
return multierr.Append(fmt.Errorf("error fetching file %s: %v", backupFilename, err), w.Close())
|
|
}
|
|
if err = w.Close(); err != nil {
|
|
return err
|
|
}
|
|
}
|
|
|
|
fmt.Printf("Backup complete")
|
|
|
|
return nil
|
|
}
|