loveuer/esgo2dump
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: put out es bulk err; more info msg

Browse Source
This commit is contained in:
loveuer
2024-03-26 18:10:19 +08:00
parent 34d1915718
commit 6c34ab15b2
2 changed files with 17 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
internal/cmd/run.go
View File

@ -28,6 +28,10 @@ func run(cmd *cobra.Command, args []string) error {
logrus.SetLevel(logrus.DebugLevel)
}
if f_limit == 0 || f_limit > 10000 {
return fmt.Errorf("invalid limit(1 - 10000)")
}
switch f_type {
case "data", "mapping", "setting":
default:
@ -86,6 +90,7 @@ func executeData(ctx context.Context, input, output interfaces.DumpIO) error {
err error
lines []*interfaces.ESSource
succeed int
total int
)
for {
@ -110,7 +115,9 @@ func executeData(ctx context.Context, input, output interfaces.DumpIO) error {
return fmt.Errorf("cmd.run: got lines=%d, only succeed=%d", len(lines), succeed)
}
logrus.Infof("Dump: %d docs succeed!!!", succeed)
total += succeed
logrus.Infof("Dump: succeed=%d total=%d docs succeed!!!", succeed, total)
}
}