如何使用OSS SDK V2進行非同步處理 - Object Storage Service

非同步處理（x-oss-async-process）是指程式執行一個任務時，不需要等待該任務完成就能繼續執行其他任務。本文介紹如何使用Go SDK V2進行非同步處理的情境，例如文檔轉換、視頻轉碼、視頻拼接等。

注意事項

本文範例程式碼以華東1（杭州）的地區IDcn-hangzhou為例，預設使用外網Endpoint，如果您希望通過與OSS同地區的其他阿里雲產品訪問OSS，請使用內網Endpoint。關於OSS支援的Region與Endpoint的對應關係，請參見OSS地區和訪問網域名稱。
本文以從環境變數讀取存取憑證為例。如何配置訪問憑證，請參見配置訪問憑證。

方法定義

func (c *Client) AsyncProcessObject(ctx context.Context, request *AsyncProcessObjectRequest, optFns ...func(*Options)) (*AsyncProcessObjectResult, error)

請求參數列表

參數名	類型	說明
ctx	context.Context	請求的上下文，可以用來佈建要求的總時限
request	*AsyncProcessObjectRequest	設定具體介面的請求參數，具體請參見AsyncProcessObjectRequest
optFns	...func(*Options)	（可選）介面級的配置參數, 具體請參見Options

傳回值列表

傳回值名	類型	說明
result	*AsyncProcessObjectResult	介面傳回值，當 err 為nil 時有效，具體請參見AsyncProcessObjectResult
err	error	請求的狀態，當請求失敗時，err 不為 nil

範例程式碼

以下代碼展示了如何使用Go SDK V2進行文檔格式轉換，將其轉換為需要的輸出類型。

package main

import (
	"context"
	"encoding/base64"
	"flag"
	"fmt"
	"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 
	objectName string
)

// init函數在main函數之前執行，用來初始化程式
func init() {
	// 設定命令列參數來指定region
	flag.StringVar(&region, "region", "", "The region in which the bucket is located.")
	// 設定命令列參數來指定bucket名稱
	flag.StringVar(&bucketName, "bucket", "", "The name of the bucket.")
	// 設定命令列參數來指定需要進行轉換的文檔名稱
	flag.StringVar(&objectName, "object", "", "The name of the object.")
}

func main() {
	flag.Parse() // 解析命令列參數

	// 檢查是否提供了地區資訊，如果沒有提供，則輸出預設參數並退出程式
	if len(region) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, region required")
	}
	// 檢查是否提供了儲存空間名稱，如果沒有提供，則輸出預設參數並退出程式
	if len(bucketName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, bucket name required")
	}
	// 檢查是否提供了對象名稱，如果沒有提供，則輸出預設參數並退出程式
	if len(objectName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, object name required")
	}

	// 建立設定物件，並使用環境變數作為憑證提供者和指定的地區
	cfg := oss.LoadDefaultConfig().
		WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
		WithRegion(region)

	client := oss.NewClient(cfg) // 使用配置建立一個新的OSS用戶端

	// 指定轉換後的檔案名稱
	targetKey := "dest.png"

	// 構建文檔處理樣式字串以及文檔轉換處理參數
	animationStyle := "doc/convert,target_png,source_docx" // 定義將源Docx文檔轉換為PNG圖片的處理規則

	// 構建處理指示，包括儲存路徑和Base64編碼的Bucket名稱和目標檔案名稱
	bucketNameEncoded := base64.URLEncoding.EncodeToString([]byte(bucketName))
	targetKeyEncoded := base64.URLEncoding.EncodeToString([]byte(targetKey))
	process := fmt.Sprintf("%s|sys/saveas,b_%v,o_%v/notify", animationStyle, bucketNameEncoded, targetKeyEncoded)

	// 構建一個AsyncProcessObject請求，用於發起對特定對象的非同步處理
	request := &oss.AsyncProcessObjectRequest{
		Bucket:       oss.Ptr(bucketName), // 指定要操作的儲存空間名稱
		Key:          oss.Ptr(objectName), // 指定要處理的文檔名稱
		AsyncProcess: oss.Ptr(process),    
	}

	// 執行請求以非同步處理對象，並接收返回結果
	result, err := client.AsyncProcessObject(context.TODO(), request)
	if err != nil {
		log.Fatalf("failed to async process object %v", err)
	}

	log.Printf("async process object result:%#v\n", result)
}

常見使用情境

視頻轉碼

您可以使用視頻轉碼功能，修改視頻的編碼格式、降低解析度和碼率以縮小視頻檔案體積、轉換視頻封裝格式。

package main

import (
	"context"
	"encoding/base64"
	"flag"
	"fmt"
	"log"
	"strings"

	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss"
	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss/credentials"
)

var (
	region     string // 定義一個變數來儲存從命令列擷取的地區（Region）資訊
	bucketName string // 定義一個變數來儲存從命令列擷取的儲存桶名稱
	objectName string // 定義一個變數來儲存從命令列擷取的對象名稱
)

func init() {
	// 設定命令列參數來指定region
	flag.StringVar(&region, "region", "", "The region in which the bucket is located.")
	// 設定命令列參數來指定bucket名稱
	flag.StringVar(&bucketName, "bucket", "", "The name of the bucket.")
	// 設定命令列參數來指定需要進行轉碼的視頻名稱
	flag.StringVar(&objectName, "object", "", "The name of the object.")
}

func main() {
	flag.Parse() // 解析命令列參數

	// 檢查是否提供了地區資訊，如果沒有提供，則輸出預設參數並退出程式
	if len(region) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, region required")
	}
	// 檢查是否提供了儲存桶名稱，如果沒有提供，則輸出預設參數並退出程式
	if len(bucketName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, bucket name required")
	}
	// 檢查是否提供了對象名稱，如果沒有提供，則輸出預設參數並退出程式
	if len(objectName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, object name required")
	}

	// 建立設定物件，並使用環境變數作為憑證提供者和指定的地區
	cfg := oss.LoadDefaultConfig().
		WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
		WithRegion(region)

	client := oss.NewClient(cfg) // 使用配置建立一個新的OSS用戶端

	// 指定轉碼後的視頻名稱
	targetObject := "dest.avi"

	// 定義處理風格，這裡是一個樣本視頻轉換配置，包括格式、視頻轉碼器、解析度、位元速率、幀率、音訊轉碼器、音頻位元速率等參數
	style := "video/convert,f_avi,vcodec_h265,s_1920x1080,vb_2000000,fps_30,acodec_aac,ab_100000,sn_1"

	// 構造非同步處理指示，包含處理風格以及處理後檔案的儲存位置（儲存桶和對象名經過Base64編碼）
	process := fmt.Sprintf("%s|sys/saveas,b_%v,o_%v",
		style,
		strings.TrimRight(base64.URLEncoding.EncodeToString([]byte(bucketName)), "="),   // Base64編碼儲存桶名稱並移除末尾的'='
		strings.TrimRight(base64.URLEncoding.EncodeToString([]byte(targetObject)), "=")) // Base64編碼對象名稱並移除末尾的'='

	// 構建一個AsyncProcessObject請求，用於發起對特定對象的非同步處理
	request := &oss.AsyncProcessObjectRequest{
		Bucket:       oss.Ptr(bucketName), // 指定要操作的儲存桶名稱
		Key:          oss.Ptr(objectName), // 指定要處理的視頻名稱
		AsyncProcess: oss.Ptr(process),
	}

	// 執行請求以非同步處理對象，並接收返回結果
	result, err := client.AsyncProcessObject(context.TODO(), request)
	if err != nil {
		log.Fatalf("failed to async process object %v", err)
	}

	log.Printf("async process object result:%#v\n", result)
}

視頻轉動圖

您可以通過視頻轉動圖功能，將視頻轉換為GIF、WebP等格式的動圖。

package main

import (
	"context"
	"encoding/base64"
	"flag"
	"fmt"
	"log"

	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss"
	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss/credentials"
)

var (
	region     string // 定義一個變數來儲存從命令列擷取的地區（Region）資訊
	bucketName string // 定義一個變數來儲存從命令列擷取的儲存空間名稱
	objectName string // 定義一個變數來儲存從命令列擷取的對象名稱
)

// init函數在main函數之前執行，用來初始化程式
func init() {
	// 設定命令列參數來指定region
	flag.StringVar(&region, "region", "", "The region in which the bucket is located.")
	// 設定命令列參數來指定bucket名稱
	flag.StringVar(&bucketName, "bucket", "", "The name of the bucket.")
	// 設定命令列參數來指定要處理的視頻名稱
	flag.StringVar(&objectName, "object", "", "The name of the object.")
}

func main() {
	flag.Parse() // 解析命令列參數

	// 檢查是否提供了地區資訊，如果沒有提供，則輸出預設參數並退出程式
	if len(region) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, region required")
	}
	// 檢查是否提供了儲存空間名稱，如果沒有提供，則輸出預設參數並退出程式
	if len(bucketName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, bucket name required")
	}
	// 檢查是否提供了對象名稱，如果沒有提供，則輸出預設參數並退出程式
	if len(objectName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, object name required")
	}

	// 建立設定物件，並使用環境變數作為憑證提供者和指定的地區
	cfg := oss.LoadDefaultConfig().
		WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
		WithRegion(region)

	client := oss.NewClient(cfg) // 使用配置建立一個新的OSS用戶端

	// 指定處理後GIF動圖檔案名稱
	targetKey := "destexample.gif"

	// 定義視頻轉GIF動圖的參數，包括GIF寬度、高度、間隔幀數等
	animationStyle := "video/animation,f_gif,w_100,h_100,inter_1000"

	// 構建處理指示，包括儲存路徑和Base64編碼的Bucket名稱和目標檔案名稱
	bucketNameEncoded := base64.URLEncoding.EncodeToString([]byte(bucketName))
	targetKeyEncoded := base64.URLEncoding.EncodeToString([]byte(targetKey))
	process := fmt.Sprintf("%s|sys/saveas,b_%v,o_%v/notify,topic_QXVkaW9Db252ZXJ0", animationStyle, bucketNameEncoded, targetKeyEncoded)

	// 構建一個AsyncProcessObject請求，用於發起對特定對象的非同步處理
	request := &oss.AsyncProcessObjectRequest{
		Bucket:       oss.Ptr(bucketName), // 指定要操作的儲存空間名稱
		Key:          oss.Ptr(objectName), // 指定要處理的視頻名稱
		AsyncProcess: oss.Ptr(process),    
	}

	// 執行請求以非同步處理對象，並接收返回結果
	result, err := client.AsyncProcessObject(context.TODO(), request)
	if err != nil {
		log.Fatalf("failed to async process object %v", err)
	}

	log.Printf("async process object result:%#v\n", result)
}

視頻截雪碧圖

您可以通過視頻截雪碧圖功能，提取視訊框架並按一定規則拼接為雪碧圖。

package main

import (
	"context"
	"encoding/base64"
	"flag"
	"fmt"
	"log"

	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss"
	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss/credentials"
)

var (
	region     string // 定義一個變數來儲存從命令列擷取的地區（Region）資訊
	bucketName string // 定義一個變數來儲存從命令列擷取的儲存空間名稱
	objectName string // 定義一個變數來儲存從命令列擷取的對象名稱
)

// init函數在main函數之前執行，用來初始化程式
func init() {
	// 設定命令列參數來指定region
	flag.StringVar(&region, "region", "", "The region in which the bucket is located.")
	// 設定命令列參數來指定bucket名稱
	flag.StringVar(&bucketName, "bucket", "", "The name of the bucket.")
	// 設定命令列參數來指定要處理的視頻名稱
	flag.StringVar(&objectName, "object", "", "The name of the object.")
}

func main() {
	flag.Parse() // 解析命令列參數

	// 檢查是否提供了地區資訊，如果沒有提供，則輸出預設參數並退出程式
	if len(region) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, region required")
	}
	// 檢查是否提供了儲存空間名稱，如果沒有提供，則輸出預設參數並退出程式
	if len(bucketName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, bucket name required")
	}
	// 檢查是否提供了對象名稱，如果沒有提供，則輸出預設參數並退出程式
	if len(objectName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, object name required")
	}

	// 建立設定物件，並使用環境變數作為憑證提供者和指定的地區
	cfg := oss.LoadDefaultConfig().
		WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
		WithRegion(region)

	client := oss.NewClient(cfg) // 使用配置建立一個新的OSS用戶端

	// 指定輸出的雪碧圖檔案名稱
	targetKey := "example.jpg"

	// 構建視頻轉雪碧圖參數。
	animationStyle := "video/sprite,f_jpg,sw_100,sh_100,inter_10000,tw_10,th_10,pad_0,margin_0"

	// 構建處理指示，包括儲存路徑和Base64編碼的Bucket名和目標檔案名
	bucketNameEncoded := base64.URLEncoding.EncodeToString([]byte(bucketName))
	targetKeyEncoded := base64.URLEncoding.EncodeToString([]byte(targetKey))
	process := fmt.Sprintf("%s|sys/saveas,b_%v,o_%v/notify,topic_QXVkaW9Db252ZXJ0", animationStyle, bucketNameEncoded, targetKeyEncoded)

	// 構建一個AsyncProcessObject請求，用於發起對特定對象的非同步處理
	request := &oss.AsyncProcessObjectRequest{
		Bucket:       oss.Ptr(bucketName), // 指定要操作的儲存空間名稱
		Key:          oss.Ptr(objectName), // 指定要處理的對象名稱
		AsyncProcess: oss.Ptr(process),    
	}

	// 執行請求以非同步處理對象，並接收返回結果
	result, err := client.AsyncProcessObject(context.TODO(), request)
	if err != nil {
		log.Fatalf("failed to async process object %v", err)
	}

	log.Printf("async process object result:%#v\n", result)
}

視頻截幀

您可以通過視頻截幀功能，按一定規則提取視訊框架並轉換為需要的圖片格式。

package main

import (
	"context"
	"encoding/base64"
	"flag"
	"fmt"
	"log"

	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss"
	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss/credentials"
)

var (
	region     string // 定義一個變數來儲存從命令列擷取的地區（Region）資訊
	bucketName string // 定義一個變數來儲存從命令列擷取的儲存空間名稱
	objectName string // 定義一個變數來儲存從命令列擷取的對象名稱
)

// init函數在main函數之前執行，用來初始化程式
func init() {
	// 設定命令列參數來指定region
	flag.StringVar(&region, "region", "", "The region in which the bucket is located.")
	// 設定命令列參數來指定bucket名稱
	flag.StringVar(&bucketName, "bucket", "", "The name of the bucket.")
	// 設定命令列參數來指定要處理的視頻名稱
	flag.StringVar(&objectName, "object", "", "The name of the object.")
}

func main() {
	flag.Parse() // 解析命令列參數

	// 檢查是否提供了地區資訊，如果沒有提供，則輸出預設參數並退出程式
	if len(region) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, region required")
	}
	// 檢查是否提供了儲存空間名稱，如果沒有提供，則輸出預設參數並退出程式
	if len(bucketName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, bucket name required")
	}
	// 檢查是否提供了對象名稱，如果沒有提供，則輸出預設參數並退出程式
	if len(objectName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, object name required")
	}

	// 建立設定物件，並使用環境變數作為憑證提供者和指定的地區
	cfg := oss.LoadDefaultConfig().
		WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
		WithRegion(region)

	client := oss.NewClient(cfg) // 使用配置建立一個新的OSS用戶端

	// 指定按視頻截幀處理後的檔案名稱
	targetKey := "dest.png"

	// 構建視頻截幀參數
	animationStyle := "video/snapshots,f_jpg,w_100,h_100,scaletype_crop,inter_10000"

	// 構建處理指示，包括儲存路徑和Base64編碼的Bucket名稱和目標檔案名稱
	bucketNameEncoded := base64.URLEncoding.EncodeToString([]byte(bucketName))
	targetKeyEncoded := base64.URLEncoding.EncodeToString([]byte(targetKey))
	process := fmt.Sprintf("%s|sys/saveas,b_%v,o_%v/notify,topic_QXVkaW9Db252ZXJ0", animationStyle, bucketNameEncoded, targetKeyEncoded)

	// 構建一個AsyncProcessObject請求，用於發起對特定對象的非同步處理
	request := &oss.AsyncProcessObjectRequest{
		Bucket:       oss.Ptr(bucketName), // 指定要操作的儲存空間名稱
		Key:          oss.Ptr(objectName), // 指定要處理的對象名稱
		AsyncProcess: oss.Ptr(process),    
	}

	// 執行請求以非同步處理對象，並接收返回結果
	result, err := client.AsyncProcessObject(context.TODO(), request)
	if err != nil {
		log.Fatalf("failed to async process object %v", err)
	}

	log.Printf("async process object result:%#v\n", result)
}

視頻拼接

您可以通過視頻拼接功能，將多個視頻拼接為一個視頻並轉換為需要的格式。

package main

import (
	"context"
	"encoding/base64"
	"flag"
	"fmt"
	"log"
	"strings"

	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss"
	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss/credentials"
)

var (
	region     string // 定義一個變數來儲存從命令列擷取的地區（Region）資訊
	bucketName string // 定義一個變數來儲存從命令列擷取的儲存空間名稱
)

// init函數在main函數之前執行，用來初始化程式
func init() {
	// 設定命令列參數來指定region
	flag.StringVar(&region, "region", "", "The region in which the bucket is located.")
	// 設定命令列參數來指定bucket名稱
	flag.StringVar(&bucketName, "bucket", "", "The name of the bucket.")
}

func main() {
	flag.Parse() // 解析命令列參數

	// 檢查是否提供了地區資訊，如果沒有提供，則輸出預設參數並退出程式
	if len(region) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, region required")
	}
	// 檢查是否提供了儲存空間名稱，如果沒有提供，則輸出預設參數並退出程式
	if len(bucketName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, bucket name required")
	}

	// 建立設定物件，並使用環境變數作為憑證提供者和指定的地區
	cfg := oss.LoadDefaultConfig().
		WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
		WithRegion(region)

	client := oss.NewClient(cfg) // 使用配置建立一個新的OSS用戶端

	// 填寫拼接後的視頻檔案名稱
	targetObject := "dest.mp4"
	// 指定需要拼接的視頻檔案名稱
	video1 := "concat1.mp4"
	video2 := "concat2.mp4"

	// 構建視頻處理的樣式字串以及視頻拼接處理參數
	style := fmt.Sprintf("video/concat,ss_0,f_mp4,vcodec_h264,fps_25,vb_1000000,acodec_aac,ab_96000,ar_48000,ac_2,align_1/pre,o_%s/sur,o_%s,t_0", strings.TrimRight(base64.URLEncoding.EncodeToString([]byte(video1)), "="), strings.TrimRight(base64.URLEncoding.EncodeToString([]byte(video2)), "="))
	// 構建非同步處理指示
	process := fmt.Sprintf("%s|sys/saveas,b_%v,o_%v/notify,topic_QXVkaW9Db252ZXJ0", style, strings.TrimRight(base64.URLEncoding.EncodeToString([]byte(bucketName)), "="), strings.TrimRight(base64.URLEncoding.EncodeToString([]byte(targetObject)), "="))

	// 構建一個AsyncProcessObject請求，用於發起對特定對象的非同步處理
	request := &oss.AsyncProcessObjectRequest{
		Bucket:       oss.Ptr(bucketName), // 指定要操作的儲存空間名稱
		AsyncProcess: oss.Ptr(process),    
	}

	// 執行請求以非同步處理對象，並接收返回結果
	result, err := client.AsyncProcessObject(context.TODO(), request)
	if err != nil {
		log.Fatalf("failed to async process object %v", err)
	}

	log.Printf("async process object result:%#v\n", result)
}

音頻轉碼

您可以通過音頻轉碼功能，將音頻轉換為需要的格式。

package main

import (
	"context"
	"encoding/base64"
	"flag"
	"fmt"
	"log"

	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss"
	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss/credentials"
)

var (
	region     string // 定義一個變數來儲存從命令列擷取的地區（Region）資訊
	bucketName string // 定義一個變數來儲存從命令列擷取的儲存空間名稱
	objectName string // 定義一個變數來儲存從命令列擷取的對象名稱
)

// init函數在main函數之前執行，用來初始化程式
func init() {
	// 設定命令列參數來指定region
	flag.StringVar(&region, "region", "", "The region in which the bucket is located.")
	// 設定命令列參數來指定bucket名稱
	flag.StringVar(&bucketName, "bucket", "", "The name of the bucket.")
	// 設定命令列參數來指定需要處理的音頻名稱
	flag.StringVar(&objectName, "object", "", "The name of the object.")
}

func main() {
	flag.Parse() // 解析命令列參數

	// 檢查是否提供了地區資訊，如果沒有提供，則輸出預設參數並退出程式
	if len(region) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, region required")
	}
	// 檢查是否提供了儲存空間名稱，如果沒有提供，則輸出預設參數並退出程式
	if len(bucketName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, bucket name required")
	}
	// 檢查是否提供了對象名稱，如果沒有提供，則輸出預設參數並退出程式
	if len(objectName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, object name required")
	}

	// 建立設定物件，並使用環境變數作為憑證提供者和指定的地區
	cfg := oss.LoadDefaultConfig().
		WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
		WithRegion(region)

	client := oss.NewClient(cfg) // 使用配置建立一個新的OSS用戶端

	// 指定轉碼後的音頻檔案
	targetKey := "dest.aac"

	// 構建音頻處理樣式字串以及音頻轉碼處理參數。
	animationStyle := "audio/convert,ss_10000,t_60000,f_aac,ab_96000"

	// 構建處理指示，包括儲存路徑和Base64編碼的Bucket名稱和目標檔案名稱。
	bucketNameEncoded := base64.URLEncoding.EncodeToString([]byte(bucketName))
	targetKeyEncoded := base64.URLEncoding.EncodeToString([]byte(targetKey))
	process := fmt.Sprintf("%s|sys/saveas,b_%v,o_%v/notify,topic_QXVkaW9Db252ZXJ0", animationStyle, bucketNameEncoded, targetKeyEncoded)

	// 構建一個AsyncProcessObject請求，用於發起對特定對象的非同步處理
	request := &oss.AsyncProcessObjectRequest{
		Bucket:       oss.Ptr(bucketName), // 指定要操作的儲存空間名稱
		Key:          oss.Ptr(objectName), // 指定需要處理的音頻名稱
		AsyncProcess: oss.Ptr(process),    
	}

	// 執行請求以非同步處理對象，並接收返回結果
	result, err := client.AsyncProcessObject(context.TODO(), request)
	if err != nil {
		log.Fatalf("failed to async process object %v", err)
	}

	log.Printf("async process object result:%#v\n", result)
}

音頻拼接

您可以通過音頻拼接功能，將多個音頻拼接為一個音頻並轉換為需要的格式。

package main

import (
	"context"
	"encoding/base64"
	"flag"
	"fmt"
	"log"

	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss"
	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss/credentials"
)

var (
	region     string // 定義一個變數來儲存從命令列擷取的地區（Region）資訊
	bucketName string // 定義一個變數來儲存從命令列擷取的儲存空間名稱
)

// init函數在main函數之前執行，用來初始化程式
func init() {
	// 設定命令列參數來指定region
	flag.StringVar(&region, "region", "", "The region in which the bucket is located.")
	// 設定命令列參數來指定bucket名稱
	flag.StringVar(&bucketName, "bucket", "", "The name of the bucket.")
}

func main() {
	flag.Parse() // 解析命令列參數

	// 檢查是否提供了地區資訊，如果沒有提供，則輸出預設參數並退出程式
	if len(region) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, region required")
	}
	// 檢查是否提供了儲存空間名稱，如果沒有提供，則輸出預設參數並退出程式
	if len(bucketName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, bucket name required")
	}

	// 建立設定物件，並使用環境變數作為憑證提供者和指定的地區
	cfg := oss.LoadDefaultConfig().
		WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
		WithRegion(region)

	client := oss.NewClient(cfg) // 使用配置建立一個新的OSS用戶端

	// 需要拼接的音頻檔案名稱。
	audio1 := "src1.mp3"
	audio2 := "src2.mp3"
	// 指定拼接後的音頻檔案名稱。
	targetAudio := "dest.aac"

	// 構建音頻處理的樣式字串以及音頻拼接處理參數。
	audio1Encoded := base64.URLEncoding.EncodeToString([]byte(audio1))
	audio2Encoded := base64.URLEncoding.EncodeToString([]byte(audio2))
	style := fmt.Sprintf("audio/concat,f_aac,ac_1,ar_44100,ab_96000,align_2/pre,o_%s/pre,o_%s,t_0", audio1Encoded, audio2Encoded)

	// 構建非同步處理指示。
	bucketEncoded := base64.URLEncoding.EncodeToString([]byte(bucketName))
	targetEncoded := base64.URLEncoding.EncodeToString([]byte(targetAudio))
	process := fmt.Sprintf("%s|sys/saveas,b_%s,o_%s/notify,topic_QXVkaW9Db252ZXJ0", style, bucketEncoded, targetEncoded)

	// 構建一個AsyncProcessObject請求，用於發起對特定對象的非同步處理
	request := &oss.AsyncProcessObjectRequest{
		Bucket:       oss.Ptr(bucketName), // 指定要操作的儲存空間名稱
		AsyncProcess: oss.Ptr(process),    
	}

	// 執行請求以非同步處理對象，並接收返回結果
	result, err := client.AsyncProcessObject(context.TODO(), request)
	if err != nil {
		log.Fatalf("failed to async process object %v", err)
	}

	log.Printf("async process object result:%#v\n", result)
}

解析圖片盲浮水印

以下代碼展示了如何解析圖片中的盲浮水印。

package main

import (
	"context"
	"encoding/base64"
	"flag"
	"fmt"
	"log"
	"strings"

	"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函數在main函數之前執行，用來初始化程式
func init() {
	// 設定命令列參數來指定region
	flag.StringVar(&region, "region", "", "The region in which the bucket is located.")
	// 設定命令列參數來指定bucket名稱
	flag.StringVar(&bucketName, "bucket", "", "The name of the bucket.")
	// 設定命令列參數來指定需要處理的圖片名稱
	flag.StringVar(&objectName, "object", "", "The name of the object.")
}

func main() {
	flag.Parse() // 解析命令列參數

	// 檢查是否提供了地區資訊，如果沒有提供，則輸出預設參數並退出程式
	if len(region) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, region required")
	}
	// 檢查是否提供了儲存空間名稱，如果沒有提供，則輸出預設參數並退出程式
	if len(bucketName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, bucket name required")
	}
	// 檢查是否提供了對象名稱，如果沒有提供，則輸出預設參數並退出程式
	if len(objectName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, object name required")
	}

	// 建立設定物件，並使用環境變數作為憑證提供者和指定的地區
	cfg := oss.LoadDefaultConfig().
		WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
		WithRegion(region)

	client := oss.NewClient(cfg) // 使用配置建立一個新的OSS用戶端

	// 指定浮水印圖檔案名稱
	sourceKey := objectName // 指定要處理的圖片對象名稱

	// 指定MNS訊息的topic。
	topic := "imm-blindwatermark-test"

	// 提取指定圖片中的浮水印內容
	style := "image/deblindwatermark,s_low,t_text"
	encodedTopic := strings.TrimRight(base64.URLEncoding.EncodeToString([]byte(topic)), "=")
	process := fmt.Sprintf("%s|sys/notify,topic_%s", style, encodedTopic)
	// 構建一個AsyncProcessObject請求，用於發起對特定對象的非同步處理
	request := &oss.AsyncProcessObjectRequest{
		Bucket:       oss.Ptr(bucketName), // 指定要操作的儲存空間名稱
		Key:          oss.Ptr(sourceKey),  // 指定要處理的圖片名稱
		AsyncProcess: oss.Ptr(process),    
	}

	// 執行請求以非同步處理對象，並接收返回結果
	result, err := client.AsyncProcessObject(context.TODO(), request)
	if err != nil {
		log.Fatalf("failed to async process object %v", err)
	}

	log.Printf("async process object result:%#v\n", result)
}

Object Storage Service：非同步處理（Go SDK V2）