默認情況下,如果新添加文件與現有文件(Object)同名且對該文件有訪問權限,則新添加的文件將覆蓋原有的文件。本文介紹如何通過設置請求頭x-oss-forbid-overwrite在簡單上傳、拷貝文件及分片上傳等場景中禁止覆蓋同名文件。
注意事項
示例代碼
以下代碼用于簡單上傳時禁止覆蓋同名文件:
package main
import (
"log"
"strings"
"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請按實際情況填寫。
client, err := oss.New("yourEndpoint", "", "", oss.SetCredentialsProvider(&provider))
if err != nil {
log.Fatalf("Failed to create OSS client: %v", err)
}
// yourBucketName填寫存儲空間名稱。
bucketName := "yourBucketName"
bucket, err := client.Bucket(bucketName)
if err != nil {
log.Fatalf("Failed to get bucket '%s': %v", bucketName, err)
}
// 指定是否覆蓋同名文件。
// 不指定oss.ForbidOverWrite時,默認覆蓋同名Object。
// 指定oss.ForbidOverWrite為false時,表示允許覆蓋同名Object。
// 指定oss.ForbidOverWrite為true時,表示禁止覆蓋同名Object,如果同名Object已存在,程序將報錯。
forbidWrite := oss.ForbidOverWrite(true)
// 上傳字符串。
// yourObjectName填寫不包含Bucket名稱在內的Object的完整路徑。
objectName := "yourObjectName"
objectValue := "yourObjectValue"
err = bucket.PutObject(objectName, strings.NewReader(objectValue), forbidWrite)
if err != nil {
log.Fatalf("Failed to upload object '%s': %v", objectName, err)
}
log.Printf("Successfully uploaded object '%s' with value '%s'", objectName, objectValue)
}
常見使用場景
拷貝文件時禁止覆蓋同名文件
以下代碼用于拷貝文件時禁止覆蓋同名文件:
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請按實際情況填寫。
client, err := oss.New("yourEndpoint", "", "", oss.SetCredentialsProvider(&provider))
if err != nil {
log.Fatalf("Failed to create OSS client: %v", err)
}
// yourBucketName填寫存儲空間名稱。
bucketName := "yourBucketName"
// yourObjectName填寫不包含Bucket名稱在內的源Object的完整路徑。
objectName := "yourObjectName"
// yourDestObjectName填寫不包含Bucket名稱在內的目標Object的完整路徑。
destObjectName := "yourDestObjectName"
// 獲取存儲空間實例。
bucket, err := client.Bucket(bucketName)
if err != nil {
log.Fatalf("Failed to get bucket '%s': %v", bucketName, err)
}
// 指定是否覆蓋同名目標文件。
// 不指定oss.ForbidOverWrite時,默認覆蓋同名目標Object。
// 指定oss.ForbidOverWrite為false時,表示允許覆蓋同名目標Object。
// 指定oss.ForbidOverWrite為true時,表示禁止覆蓋同名目標Object,如果同名目標Object已存在,程序將報錯。
forbidWrite := oss.ForbidOverWrite(true)
// 拷貝文件到同一個存儲空間的另一個文件。
_, err = bucket.CopyObject(objectName, destObjectName, forbidWrite)
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)
}
分片上傳時禁止覆蓋同名文件
以下代碼用于分片上傳時禁止覆蓋同名文件:
package main
import (
"log"
"os"
"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請按實際情況填寫。
client, err := oss.New("yourEndpoint", "", "", oss.SetCredentialsProvider(&provider))
if err != nil {
log.Fatalf("Failed to create OSS client: %v", err)
}
// yourBucketName填寫存儲空間名稱。
bucketName := "yourBucketName"
// yourObjectName填寫不包含Bucket名稱在內的Object的完整路徑。
objectName := "yourObjectName"
// yourLocalFilename填寫本地文件的完整路徑。
localFilename := "yourLocalFilename"
// 獲取存儲空間實例。
bucket, err := client.Bucket(bucketName)
if err != nil {
log.Fatalf("Failed to get bucket '%s': %v", bucketName, err)
}
// 分割文件為多個塊。
chunks, err := oss.SplitFileByPartNum(localFilename, 3)
if err != nil {
log.Fatalf("Failed to split file: %v", err)
}
// 打開本地文件。
fd, err := os.Open(localFilename)
if err != nil {
log.Fatalf("Failed to open local file '%s': %v", localFilename, err)
}
defer fd.Close()
// 指定是否覆蓋同名文件。
// 不指定oss.ForbidOverWrite時,默認覆蓋同名Object。
// 指定oss.ForbidOverWrite為false時,表示允許覆蓋同名Object。
// 指定oss.ForbidOverWrite為true時,表示禁止覆蓋同名Object,如果同名Object已存在,程序將報錯。
forbidWrite := oss.ForbidOverWrite(true)
// 步驟1:初始化一個分片上傳事件。
imur, err := bucket.InitiateMultipartUpload(objectName, forbidWrite)
if err != nil {
log.Fatalf("Failed to initiate multipart upload for '%s': %v", objectName, err)
}
// 步驟2:上傳分片。
var parts []oss.UploadPart
for _, chunk := range chunks {
fd.Seek(chunk.Offset, os.SEEK_SET)
// 對每個分片調用UploadPart方法上傳。
part, err := bucket.UploadPart(imur, fd, chunk.Size, chunk.Number)
if err != nil {
log.Fatalf("Failed to upload part %d of '%s': %v", chunk.Number, objectName, err)
}
parts = append(parts, part)
}
// 步驟3:完成分片上傳,禁止覆蓋同名文件。
cmur, err := bucket.CompleteMultipartUpload(imur, parts, forbidWrite)
if err != nil {
log.Fatalf("Failed to complete multipart upload for '%s': %v", objectName, err)
}
log.Printf("Multipart upload completed successfully for '%s'. cmur: %v", objectName, cmur)
}
相關文檔
關于簡單上傳的API接口說明,請參見PutObject。
關于拷貝文件的API接口說明,請參見CopyObject。
關于分片上傳的API接口說明,請參見InitiateMultipartUpload以及CompleteMultipartUpload。
文檔內容是否對您有幫助?