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

同步處理（x-oss-process）是指程式執行一個任務時，必須等待該任務完成才能繼續執行其他任務。本文介紹如何使用Go SDK V2進行同步處理的情境，例如圖片處理、文檔處理等。

注意事項

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

方法定義

func (c *Client) ProcessObject(ctx context.Context, request *ProcessObjectRequest, optFns ...func(*Options)) (*ProcessObjectResult, error)

請求參數列表

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

傳回值列表

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

範例程式碼

以下代碼展示了如何使用Go SDK V2進行圖片縮放的操作，並將處理後的圖片持久化儲存至指定的Bucket。

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用戶端

	// 指定用於存放處理後圖片的Bucket名稱，該Bucket需與原圖所在Bucket在同一地區
	targetBucketName := bucketName
	// 指定處理後圖片名稱。如果圖片不在Bucket根目錄，需攜帶檔案完整訪問路徑，例如exampledir/example.jpg
	targetImageName := "exampledir/example.jpg"
	// 將圖片縮放為固定寬高100 px後轉存到指定儲存空間
	style := "image/resize,m_fixed,w_100,h_100"
	process := fmt.Sprintf("%s|sys/saveas,o_%v,b_%v", style, base64.URLEncoding.EncodeToString([]byte(targetImageName)), base64.URLEncoding.EncodeToString([]byte(targetBucketName)))

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

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

	log.Printf("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
	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用戶端

	// 指定浮水印內容
	content := "阿里雲著作權"

	// 產生圖片盲浮水印
	encodedContent := base64.URLEncoding.EncodeToString([]byte(content))
	style := fmt.Sprintf("image/blindwatermark,content_%s", encodedContent)
	targetImageName := "targetDir/target.jpg"
	process := fmt.Sprintf("%s|sys/saveas,o_%s,b_%s", style, base64.URLEncoding.EncodeToString([]byte(targetImageName)), base64.URLEncoding.EncodeToString([]byte(bucketName)))

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

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

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

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

注意事項

方法定義

請求參數列表

傳回值列表

範例程式碼

常見使用情境

圖片添加盲浮水印

相關文檔