Object Storage Service:Processamento síncrono (Go SDK V2)

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

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
)

// The init function is executed before the main function to initialize the program.
func init() {
	// Set a command-line parameter to specify the region.
	flag.StringVar(&region, "region", "", "The region in which the bucket is located.")
	// Set a command-line parameter to specify the bucket name.
	flag.StringVar(&bucketName, "bucket", "", "The name of the bucket.")
	// Set a command-line parameter to specify the name of the image to be processed.
	flag.StringVar(&objectName, "object", "", "The name of the object.")
}

func main() {
	flag.Parse() // Parse command-line parameters.

	// Check whether the region information is provided. If not, print the default parameters and exit the program.
	if len(region) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, region required")
	}
	// Check whether the bucket name is provided. If not, print the default parameters and exit the program.
	if len(bucketName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, bucket name required")
	}
	// Check whether the object name is provided. If not, print the default parameters and exit the program.
	if len(objectName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, object name required")
	}

	// Create a configuration object, and use environment variables as the credential provider and the specified region.
	cfg := oss.LoadDefaultConfig().
		WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
		WithRegion(region)

	client := oss.NewClient(cfg) // Create a new OSS client using the configuration.

	// Specify the name of the bucket used to store the processed image. The bucket must be in the same region as the bucket that stores the source image.
	targetBucketName := bucketName
	// Specify the name of the processed image. If the image is not in the root directory of the bucket, you must include the full path of the file, for example, exampledir/example.jpg.
	targetImageName := "exampledir/example.jpg"
	// Resize the image to a fixed width and height of 100 px and save it to the specified bucket.
	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)))

	// Build a ProcessObjectRequest to initiate synchronous processing for a specific object.
	request := &oss.ProcessObjectRequest{
		Bucket:  oss.Ptr(bucketName), // Specify the name of the bucket to operate on.
		Key:     oss.Ptr(objectName), // Specify the name of the image to process.
		Process: oss.Ptr(process),    // Specify the processing instruction.
	}

	// Execute the request to synchronously process the object and receive the return value.
	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)
}