Browse Source

提交代码。

Signed-off-by: zouap <zouap@pcl.ac.cn>
tags/v1.21.12.1^2
zouap 4 years ago
parent
commit
c9bc52a8a6
1 changed files with 3 additions and 7 deletions
  1. +3
    -7
      modules/storage/obs.go

+ 3
- 7
modules/storage/obs.go View File

@@ -236,13 +236,8 @@ func ObsCopyManyFile(srcBucket string, srcPath string, destBucket string, destPa
log.Info("Page:%d\n", index)
index++
for _, val := range output.Contents {
// if strings.HasSuffix(val.Key, "/") {
// log.Info("copy file, src key=" + val.Key + " is dir, not copy.")
// continue
// }
destKey := destPath + val.Key[length:]
log.Info("copy file,bucket=" + srcBucket + " src key=" + val.Key + "destbucket=" + destBucket + " dest key=" + destKey)
ObsCopyFile(srcBucket, val.Key, destBucket, destKey)
obsCopyFile(srcBucket, val.Key, destBucket, destKey)
fileTotalSize += val.Size
}
if output.IsTruncated {
@@ -261,7 +256,7 @@ func ObsCopyManyFile(srcBucket string, srcPath string, destBucket string, destPa
return fileTotalSize, nil
}

func ObsCopyFile(srcBucket string, srcKeyName string, destBucket string, destKeyName string) error {
func obsCopyFile(srcBucket string, srcKeyName string, destBucket string, destKeyName string) error {
input := &obs.CopyObjectInput{}
input.Bucket = destBucket
input.Key = destKeyName
@@ -271,6 +266,7 @@ func ObsCopyFile(srcBucket string, srcKeyName string, destBucket string, destKey
if err == nil {
log.Info("copy success,destBuckName:%s, destkeyname:%s", destBucket, destKeyName)
} else {
log.Info("copy failed,,destBuckName:%s, destkeyname:%s", destBucket, destKeyName)
if obsError, ok := err.(obs.ObsError); ok {
log.Info(obsError.Code)
log.Info(obsError.Message)


Loading…
Cancel
Save