傳輸加速可提升全球各地用戶對OSS的訪問速度,適用于遠距離數據傳輸、GB或TB級大文件上傳和下載的場景。
注意事項
本文示例代碼以華東1(杭州)的地域ID
cn-hangzhou
為例,默認使用外網Endpoint,如果您希望通過與OSS同地域的其他阿里云產品訪問OSS,請使用內網Endpoint。關于OSS支持的Region與Endpoint的對應關系,請參見OSS地域和訪問域名。本文以從環境變量讀取訪問憑證為例。如何配置訪問憑證,請參見配置訪問憑證。
示例代碼
開啟傳輸加速
以下代碼用于開啟Bucket的傳輸加速功能:
package main
import (
"context"
"flag"
"log"
"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss"
"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss/credentials"
)
// 定義全局變量
var (
region string // 存儲區域
bucketName string // 存儲空間名稱
)
// init函數用于初始化命令行參數
func init() {
flag.StringVar(®ion, "region", "", "The region in which the bucket is located.")
flag.StringVar(&bucketName, "bucket", "", "The name of the bucket.")
}
func main() {
// 解析命令行參數
flag.Parse()
// 檢查bucket名稱是否為空
if len(bucketName) == 0 {
flag.PrintDefaults()
log.Fatalf("invalid parameters, bucket name required")
}
// 檢查region是否為空
if len(region) == 0 {
flag.PrintDefaults()
log.Fatalf("invalid parameters, region required")
}
// 加載默認配置并設置憑證提供者和區域
cfg := oss.LoadDefaultConfig().
WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
WithRegion(region)
// 創建OSS客戶端
client := oss.NewClient(cfg)
// 創建設置存儲空間傳輸加速的請求
request := &oss.PutBucketTransferAccelerationRequest{
Bucket: oss.Ptr(bucketName), // 存儲空間名稱
TransferAccelerationConfiguration: &oss.TransferAccelerationConfiguration{
Enabled: oss.Ptr(true), // 啟用傳輸加速
},
}
// 執行設置存儲空間傳輸加速的請求
result, err := client.PutBucketTransferAcceleration(context.TODO(), request)
if err != nil {
log.Fatalf("failed to put bucket transfer acceleration %v", err)
}
// 打印設置存儲空間傳輸加速的結果
log.Printf("put bucket transfer acceleration result:%#v\n", result)
}
查詢傳輸加速狀態
以下代碼用于查詢Bucket的傳輸加速狀態:
package main
import (
"context"
"flag"
"log"
"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss"
"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss/credentials"
)
// 定義全局變量
var (
region string // 存儲區域
bucketName string // 存儲空間名稱
)
// init函數用于初始化命令行參數
func init() {
flag.StringVar(®ion, "region", "", "The region in which the bucket is located.")
flag.StringVar(&bucketName, "bucket", "", "The name of the bucket.")
}
func main() {
// 解析命令行參數
flag.Parse()
// 檢查bucket名稱是否為空
if len(bucketName) == 0 {
flag.PrintDefaults()
log.Fatalf("invalid parameters, bucket name required")
}
// 檢查region是否為空
if len(region) == 0 {
flag.PrintDefaults()
log.Fatalf("invalid parameters, region required")
}
// 加載默認配置并設置憑證提供者和區域
cfg := oss.LoadDefaultConfig().
WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
WithRegion(region)
// 創建OSS客戶端
client := oss.NewClient(cfg)
// 創建獲取存儲空間傳輸加速的請求
request := &oss.GetBucketTransferAccelerationRequest{
Bucket: oss.Ptr(bucketName), // 存儲空間名稱
}
// 執行獲取存儲空間傳輸加速配置的操作
result, err := client.GetBucketTransferAcceleration(context.TODO(), request)
if err != nil {
log.Fatalf("failed to get bucket transfer acceleration %v", err)
}
// 輸出存儲空間的傳輸加速狀態
log.Printf("get bucket transfer acceleration result:%#v\n", result.TransferAccelerationConfiguration.Enabled)
}
相關文檔
關于傳輸加速的完整代碼示例,請參見put_bucket_transfer_acceleration.go和get_bucket_transfer_acceleration.go。
關于開啟傳輸加速的API接口說明,請參見PutBucketTransferAcceleration。
關于查詢傳輸加速狀態的API接口說明,請參見GetBucketTransferAcceleration。
文檔內容是否對您有幫助?