aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2018-11-04 12:07:33 -0800
committerChris Lu <chris.lu@gmail.com>2018-11-04 12:07:33 -0800
commit6c45787a371b6cc1416f50c927e738639ba83f13 (patch)
tree7d0d64dd63f73e75808ae1d59468dd5ab3ab38d0
parentff4189ab2505450913c4fb273365161a80da45bf (diff)
downloadseaweedfs-6c45787a371b6cc1416f50c927e738639ba83f13.tar.xz
seaweedfs-6c45787a371b6cc1416f50c927e738639ba83f13.zip
selectively export files
-rw-r--r--weed/command/filer_export.go3
-rw-r--r--weed/command/filer_replication.go2
2 files changed, 3 insertions, 2 deletions
diff --git a/weed/command/filer_export.go b/weed/command/filer_export.go
index 98ccb4d7d..85259408e 100644
--- a/weed/command/filer_export.go
+++ b/weed/command/filer_export.go
@@ -34,6 +34,7 @@ var (
// filerExportOutputFile = cmdFilerExport.Flag.String("output", "", "the output file. If empty, only list out the directory tree")
filerExportSourceStore = cmdFilerExport.Flag.String("sourceStore", "", "the source store name in filer.toml")
filerExportTargetStore = cmdFilerExport.Flag.String("targetStore", "", "the target store name in filer.toml, or \"notification\" to export all files to message queue")
+ dir = cmdFilerExport.Flag.String("dir", "/", "only process files under this directory")
dirListLimit = cmdFilerExport.Flag.Int("dirListLimit", 100000, "limit directory list size")
dryRun = cmdFilerExport.Flag.Bool("dryRun", false, "not actually moving data")
)
@@ -127,7 +128,7 @@ func runFilerExport(cmd *Command, args []string) bool {
}
}
- doTraverse(&stat, sourceStore, filer2.FullPath("/"), 0, fn)
+ doTraverse(&stat, sourceStore, filer2.FullPath(*dir), 0, fn)
glog.Infof("processed %d directories, %d files", stat.directoryCount, stat.fileCount)
diff --git a/weed/command/filer_replication.go b/weed/command/filer_replication.go
index 9639ac98a..4ceb5ce4c 100644
--- a/weed/command/filer_replication.go
+++ b/weed/command/filer_replication.go
@@ -116,7 +116,7 @@ func runFilerReplicate(cmd *Command, args []string) bool {
if err = replicator.Replicate(key, m); err != nil {
glog.Errorf("replicate %s: %+v", key, err)
} else {
- glog.V(4).Infof("replicated %s", key)
+ glog.V(1).Infof("replicated %s", key)
}
}