本文介紹如何將源Bucket中的文件(Object)復制到同一地域下相同或不同目標Bucket中。
注意事項
本文以華東1(杭州)外網Endpoint為例。如果您希望通過與OSS同地域的其他阿里云產品訪問OSS,請使用內網Endpoint。關于OSS支持的Region與Endpoint的對應關系,請參見OSS訪問域名、數據中心、開放端口。
本文以從環境變量讀取訪問憑證為例。如何配置訪問憑證,請參見配置訪問憑證。
本文以OSS域名新建OSSClient為例。如果您希望通過自定義域名、STS等方式新建OSSClient,請參見初始化。
拷貝文件時,您必須擁有源文件的讀權限及目標Bucket的讀寫權限。
拷貝文件時,您需要確保源Bucket和目標Bucket均未設置合規保留策略,否則報錯The object you specified is immutable.。
不支持跨地域拷貝。例如不能將華東1(杭州)地域存儲空間中的文件拷貝到華北1(青島)地域。
示例代碼
拷貝小文件
您可以通過CopyObject
方法在同一個Bucket或者同一個Region下的不同Bucket之間拷貝文件,文件大小建議小于1 GB。
在同一個Bucket中拷貝文件
package main
import (
"log"
"time"
"github.com/aliyun/aliyun-oss-go-sdk/oss"
)
func main() {
// 從環境變量中獲取訪問憑證。運行本代碼示例之前,請確保已設置環境變量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。
provider, err := oss.NewEnvironmentVariableCredentialsProvider()
if err != nil {
log.Fatalf("Failed to create credentials provider: %v", err)
}
// 創建OSSClient實例。
// yourEndpoint填寫Bucket對應的Endpoint,以華東1(杭州)為例,填寫為https://oss-cn-hangzhou.aliyuncs.com。其它Region請按實際情況填寫。
// yourRegion填寫Bucket所在地域,以華東1(杭州)為例,填寫為cn-hangzhou。其它Region請按實際情況填寫。
clientOptions := []oss.ClientOption{oss.SetCredentialsProvider(&provider)}
clientOptions = append(clientOptions, oss.Region("yourRegion"))
// 設置簽名版本
clientOptions = append(clientOptions, oss.AuthVersion(oss.AuthV4))
client, err := oss.New("yourEndpoint", "", "", clientOptions...)
if err != nil {
log.Fatalf("Failed to create OSS client: %v", err)
}
// 填寫Bucket名稱,例如examplebucket。
bucketName := "examplebucket"
// 填寫拷貝前文件的完整路徑,例如srcdir/srcobject.jpg。
objectName := "srcdir/srcobject.jpg"
// 填寫拷貝后文件的完整路徑,例如destdir/destobject.jpg。
destObjectName := "destdir/destobject.jpg"
// 獲取存儲空間。
bucket, err := client.Bucket(bucketName)
if err != nil {
log.Fatalf("Failed to get bucket '%s': %v", bucketName, err)
}
// 指定目標文件的元數據。
expires := time.Date(2049, time.January, 10, 23, 0, 0, 0, time.UTC)
tag1 := oss.Tag{
Key: "a",
Value: "1",
}
taggingInfo := oss.Tagging{
Tags: []oss.Tag{tag1},
}
options := []oss.Option{
oss.MetadataDirective(oss.MetaReplace),
oss.Expires(expires),
oss.SetTagging(taggingInfo),
// 指定復制源Object的對象標簽到目標 Object。
// oss.TaggingDirective(oss.TaggingCopy),
// 指定創建目標Object時的訪問權限ACL為私有。
// oss.ObjectACL(oss.ACLPrivate),
// 指定KMS托管的用戶主密鑰,該參數僅在x-oss-server-side-encryption為KMS時有效。
// oss.ServerSideEncryptionKeyID("9468da86-3509-4f8d-a61e-6eab1eac****"),
// 指定OSS創建目標Object時使用的服務器端加密算法。
// oss.ServerSideEncryption("AES256"),
// 指定復制源Object的元數據到目標Object。
// oss.MetadataDirective(oss.MetaCopy),
// 指定CopyObject操作時是否覆蓋同名目標Object。此處設置為true,表示禁止覆蓋同名Object。
// oss.ForbidOverWrite(true),
// 如果源Object的ETag值和您提供的ETag相等,則執行拷貝操作,并返回200 OK。
// oss.CopySourceIfMatch("5B3C1A2E053D763E1B002CC607C5****"),
// 如果源Object的ETag值和您提供的ETag不相等,則執行拷貝操作,并返回200 OK。
// oss.CopySourceIfNoneMatch("5B3C1A2E053D763E1B002CC607C5****"),
// 如果指定的時間早于文件實際修改時間,則正??截愇募⒎祷?00 OK。
// oss.CopySourceIfModifiedSince(time.Date(2021, time.December, 9, 7, 1, 56, 0, time.UTC)),
// 如果指定的時間等于或者晚于文件實際修改時間,則正常拷貝文件,并返回200 OK。
// oss.CopySourceIfUnmodifiedSince(time.Date(2021, time.December, 9, 7, 1, 56, 0, time.UTC)),
// 指定Object的存儲類型。此處設置為Standard,表示標準存儲類型。
// oss.StorageClass("Standard"),
}
// 使用指定的元數據覆蓋源文件的元數據。
_, err = bucket.CopyObject(objectName, destObjectName, options...)
if err != nil {
log.Fatalf("Failed to copy object from '%s' to '%s': %v", objectName, destObjectName, err)
}
log.Printf("Successfully copied object from '%s' to '%s'", objectName, destObjectName)
}
在同一個Region下不同Bucket之間拷貝文件
package main
import (
"log"
"github.com/aliyun/aliyun-oss-go-sdk/oss"
)
func main() {
// 從環境變量中獲取訪問憑證。運行本代碼示例之前,請確保已設置環境變量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。
provider, err := oss.NewEnvironmentVariableCredentialsProvider()
if err != nil {
log.Fatalf("Failed to create credentials provider: %v", err)
}
// 創建OSSClient實例。
// yourEndpoint填寫Bucket對應的Endpoint,以華東1(杭州)為例,填寫為https://oss-cn-hangzhou.aliyuncs.com。其它Region請按實際情況填寫。
// yourRegion填寫Bucket所在地域,以華東1(杭州)為例,填寫為cn-hangzhou。其它Region請按實際情況填寫。
clientOptions := []oss.ClientOption{oss.SetCredentialsProvider(&provider)}
clientOptions = append(clientOptions, oss.Region("yourRegion"))
// 設置簽名版本
clientOptions = append(clientOptions, oss.AuthVersion(oss.AuthV4))
client, err := oss.New("yourEndpoint", "", "", clientOptions...)
if err != nil {
log.Fatalf("Failed to create OSS client: %v", err)
}
// 填寫源Bucket名稱,例如srcbucket。
srcBucketName := "srcbucket"
// 填寫拷貝前文件的完整路徑,例如srcobject.jpg。
srcObjectName := "srcobject.jpg"
// 填寫拷貝后文件的完整路徑,例如destobject.jpg。
dstObjectName := "destobject.jpg"
// 填寫目標Bucket名稱,例如destbucket。
destBucketName := "destbucket"
// 獲取目標Bucket實例。
bucket, err := client.Bucket(destBucketName)
if err != nil {
log.Fatalf("Failed to get bucket '%s': %v", destBucketName, err)
}
// 將srcbucket中的srcobject.jpg文件拷貝至destbucket內的destobject.jpg文件。
_, err = bucket.CopyObjectFrom(srcBucketName, srcObjectName, dstObjectName)
if err != nil {
log.Fatalf("Failed to copy object from '%s/%s' to '%s/%s': %v", srcBucketName, srcObjectName, destBucketName, dstObjectName, err)
}
log.Printf("Successfully copied object from '%s/%s' to '%s/%s'", srcBucketName, srcObjectName, destBucketName, dstObjectName)
}
拷貝大文件
以下代碼用于拷貝大文件:
package main
import (
"log"
"github.com/aliyun/aliyun-oss-go-sdk/oss"
)
func main() {
// 從環境變量中獲取訪問憑證。運行本代碼示例之前,請確保已設置環境變量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。
provider, err := oss.NewEnvironmentVariableCredentialsProvider()
if err != nil {
log.Fatalf("Failed to create credentials provider: %v", err)
}
// 創建OSSClient實例。
// yourEndpoint填寫Bucket對應的Endpoint,以華東1(杭州)為例,填寫為https://oss-cn-hangzhou.aliyuncs.com。其它Region請按實際情況填寫。
// yourRegion填寫Bucket所在地域,以華東1(杭州)為例,填寫為cn-hangzhou。其它Region請按實際情況填寫。
clientOptions := []oss.ClientOption{oss.SetCredentialsProvider(&provider)}
clientOptions = append(clientOptions, oss.Region("yourRegion"))
// 設置簽名版本
clientOptions = append(clientOptions, oss.AuthVersion(oss.AuthV4))
client, err := oss.New("yourEndpoint", "", "", clientOptions...)
if err != nil {
log.Fatalf("Failed to create OSS client: %v", err)
}
// 填寫Bucket名稱,例如examplebucket。
bucketName := "examplebucket"
// 獲取存儲空間。
bucket, err := client.Bucket(bucketName)
if err != nil {
log.Fatalf("Failed to get bucket '%s': %v", bucketName, err)
}
// 指定拷貝前文件的完整路徑,例如srcobject.txt。
objectSrc := "srcobject.txt"
// 指定拷貝后文件的完整路徑,例如destobject.txt。
objectDest := "destobject.txt"
// 填寫本地文件完整路徑。
fileName := "D:\\localpath\\examplefile.txt"
// 分割文件為多個塊。
chunks, err := oss.SplitFileByPartNum(fileName, 3)
if err != nil {
log.Fatalf("Failed to split file: %v", err)
}
// 上傳文件到OSS。
err = bucket.PutObjectFromFile(objectSrc, fileName)
if err != nil {
log.Fatalf("Failed to upload object '%s' from file '%s': %v", objectSrc, fileName, err)
}
// 初始化分段上傳。
imur, err := bucket.InitiateMultipartUpload(objectDest)
if err != nil {
log.Fatalf("Failed to initiate multipart upload for '%s': %v", objectDest, err)
}
var parts []oss.UploadPart
for _, chunk := range chunks {
// 設置分段上傳選項。
options := []oss.Option{}
// 執行分段拷貝。
part, err := bucket.UploadPartCopy(imur, bucketName, objectSrc, chunk.Offset, chunk.Size, chunk.Number, options...)
if err != nil {
log.Fatalf("Failed to upload part %d of '%s': %v", chunk.Number, objectSrc, err)
}
parts = append(parts, part)
}
// 完成分段上傳。
cmur, err := bucket.CompleteMultipartUpload(imur, parts)
if err != nil {
log.Fatalf("Failed to complete multipart upload for '%s': %v", objectDest, err)
}
log.Printf("Multipart upload completed successfully for '%s'. cmur: %v", objectDest, cmur)
}
相關文檔
關于拷貝文件的完整示例代碼,請參見GitHub示例。
關于拷貝小文件的API接口說明,請參見CopyObject。
關于拷貝大文件的API接口說明,請參見UploadPartCopy。
文檔內容是否對您有幫助?