OSS提供的分區上傳（Multipart Upload）功能，將要上傳的較大檔案（Object）分成多個分區（Part）來分別上傳，上傳完成後再調用CompleteMultipartUpload介面將這些Part組合成一個Object。
注意事項
本文範例程式碼以華東1（杭州）的地區ID
cn-hangzhou為例，預設使用外網Endpoint，如果您希望通過與OSS同地區的其他阿里雲產品訪問OSS，請使用內網Endpoint。關於OSS支援的Region與Endpoint的對應關係，請參見OSS地區和訪問網域名稱。本文以從環境變數讀取存取憑證為例。如何配置訪問憑證，請參見配置訪問憑證。
要分區上傳，您必須有
oss:PutObject許可權。具體操作，請參見為RAM使用者授權自訂的權限原則。
分區上傳流程
分區上傳（Multipart Upload）分為以下三個步驟：
初始化一個分區上傳事件。
調用Client.InitiateMultipartUpload方法返回OSS建立的全域唯一的uploadID。
上傳分區。
調用Client.UploadPart方法上傳分區資料。
說明對於同一個uploadID，分區號（partNumber）標識了該分區在整個檔案內的相對位置。如果使用同一個分區號上傳了新的資料，那麼OSS上該分區已有的資料將會被覆蓋。
OSS將收到的分區資料的MD5值放在ETag頭內返回給使用者。
OSS計算上傳資料的MD5值，並與SDK計算的MD5值比較，如果不一致則返回InvalidDigest錯誤碼。
完成分區上傳。
所有分區上傳完成後，調用Client.CompleteMultipartUpload方法將所有分區合并成完整的檔案。
範例程式碼
以下代碼展示如何將本地的大檔案分割成多個分區檔案並發上傳到儲存空間，然後合并成完整的檔案對象。
package main
import (
"bufio"
"bytes"
"context"
"flag"
"io"
"log"
"os"
"sync"
"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss"
"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss/credentials"
)
// 定義全域變數
var (
region string // 儲存地區
bucketName string // 源儲存空間名稱
objectName string // 來源物件名稱
)
// init函數用於初始化命令列參數
func init() {
flag.StringVar(®ion, "region", "", "The region in which the bucket is located.")
flag.StringVar(&bucketName, "bucket", "", "The name of the source bucket.")
flag.StringVar(&objectName, "object", "", "The name of the source object.")
}
func main() {
// 解析命令列參數
flag.Parse()
// 定義上傳ID
var uploadId string
// 檢查源儲存空間名稱是否為空白
if len(bucketName) == 0 {
flag.PrintDefaults()
log.Fatalf("invalid parameters, source bucket name required")
}
// 檢查儲存地區是否為空白
if len(region) == 0 {
flag.PrintDefaults()
log.Fatalf("invalid parameters, region required")
}
// 檢查來源物件名稱是否為空白
if len(objectName) == 0 {
flag.PrintDefaults()
log.Fatalf("invalid parameters, source object name required")
}
// 載入預設配置並設定憑證提供者和地區
cfg := oss.LoadDefaultConfig().
WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
WithRegion(region)
// 建立OSS用戶端
client := oss.NewClient(cfg)
// 初始化分區上傳請求
initRequest := &oss.InitiateMultipartUploadRequest{
Bucket: oss.Ptr(bucketName),
Key: oss.Ptr(objectName),
}
initResult, err := client.InitiateMultipartUpload(context.TODO(), initRequest)
if err != nil {
log.Fatalf("failed to initiate multipart upload %v", err)
}
// 列印初始化分區上傳的結果
log.Printf("initiate multipart upload result:%#v\n", *initResult.UploadId)
uploadId = *initResult.UploadId
// 初始化等待組和互斥鎖
var wg sync.WaitGroup
var parts []oss.UploadPart
count := 3
var mu sync.Mutex
// 讀取本地檔案內容到記憶體，將yourLocalFile替換為實際的本地檔案名稱和路徑
file, err := os.Open("yourLocalFile")
if err != nil {
log.Fatalf("failed to open local file %v", err)
}
defer file.Close()
bufReader := bufio.NewReader(file)
content, err := io.ReadAll(bufReader)
if err != nil {
log.Fatalf("failed to read local file %v", err)
}
log.Printf("file size: %d\n", len(content))
// 計算每個分區的大小
chunkSize := len(content) / count
if chunkSize == 0 {
chunkSize = 1
}
// 啟動多個goroutine進行分區上傳
for i := 0; i < count; i++ {
start := i * chunkSize
end := start + chunkSize
if i == count-1 {
end = len(content)
}
wg.Add(1)
go func(partNumber int, start, end int) {
defer wg.Done()
// 建立分區上傳請求
partRequest := &oss.UploadPartRequest{
Bucket: oss.Ptr(bucketName), // 目標儲存空間名稱
Key: oss.Ptr(objectName), // 目標對象名稱
PartNumber: int32(partNumber), // 分區編號
UploadId: oss.Ptr(uploadId), // 上傳ID
Body: bytes.NewReader(content[start:end]), // 分區內容
}
// 發送分區上傳請求
partResult, err := client.UploadPart(context.TODO(), partRequest)
if err != nil {
log.Fatalf("failed to upload part %d: %v", partNumber, err)
}
// 記錄分區上傳結果
part := oss.UploadPart{
PartNumber: partRequest.PartNumber,
ETag: partResult.ETag,
}
// 使用互斥鎖保護共用資料
mu.Lock()
parts = append(parts, part)
mu.Unlock()
}(i+1, start, end)
}
// 等待所有goroutine完成
wg.Wait()
// 完成分區上傳請求
request := &oss.CompleteMultipartUploadRequest{
Bucket: oss.Ptr(bucketName),
Key: oss.Ptr(objectName),
UploadId: oss.Ptr(uploadId),
CompleteMultipartUpload: &oss.CompleteMultipartUpload{
Parts: parts,
},
}
result, err := client.CompleteMultipartUpload(context.TODO(), request)
if err != nil {
log.Fatalf("failed to complete multipart upload %v", err)
}
// 列印完成分區上傳的結果
log.Printf("complete multipart upload result:%#v\n", result)
}
常見使用情境
將指定長度的隨機字串進行分區上傳
取消指定的分區上傳事件
列舉指定的分區上傳事件中已經成功上傳的分區
列舉分區上傳事件
分區上傳時設定回呼函數
相關文檔
關於分區上傳的完整範例程式碼，請參見GitHub樣本。
分區上傳的完整實現涉及三個API介面，詳情如下：
關於初始化分區上傳事件的API介面說明，請參見InitiateMultipartUpload。
關於分區上傳Part的API介面說明，請參見UploadPart。
關於完成分區上傳的API介面說明，請參見CompleteMultipartUpload。
關於取消分區上傳事件的API介面說明，請參見AbortMultipartUpload。
關於列舉已上傳分區的API介面說明，請參見NewListPartsPaginator。
關於列舉所有執行中的分區上傳事件（即已初始化但尚未完成或已取消的分區上傳事件）的API介面說明，請參見NewListMultipartUploadsPaginator。