Object Storage Service:Manage bucket inventory using OSS SDK for Go 2.0

Use PutBucketInventoryRequest to submit the inventory configuration. The destination bucket, RAM role ARN, and schedule frequency are required fields.

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
)

func init() {
	flag.StringVar(&region, "region", "", "The region where the bucket is located.")
	flag.StringVar(&bucketName, "bucket", "", "The bucket name.")
}

func main() {
	flag.Parse()

	var (
		accountId   = "account id of the bucket" // Alibaba Cloud account ID granted permissions by the bucket owner. Example: 109885487000****.
		inventoryId = "inventory id"             // Inventory name. Must be unique within the bucket.
	)

	if len(bucketName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, bucket name required")
	}

	if len(region) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, region required")
	}

	cfg := oss.LoadDefaultConfig().
		WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
		WithRegion(region)

	client := oss.NewClient(cfg)

	request := &oss.PutBucketInventoryRequest{
		Bucket:      oss.Ptr(bucketName),
		InventoryId: oss.Ptr(inventoryId),
		InventoryConfiguration: &oss.InventoryConfiguration{
			Id:        oss.Ptr(inventoryId),
			IsEnabled: oss.Ptr(true),
			Filter: &oss.InventoryFilter{
				Prefix:                   oss.Ptr("filterPrefix"),    // Filter objects by prefix.
				LastModifyBeginTimeStamp: oss.Ptr(int64(1637883649)), // Unix timestamp: filter start time.
				LastModifyEndTimeStamp:   oss.Ptr(int64(1638347592)), // Unix timestamp: filter end time.
				LowerSizeBound:           oss.Ptr(int64(1024)),       // Minimum object size in bytes.
				UpperSizeBound:           oss.Ptr(int64(1048576)),    // Maximum object size in bytes.
				StorageClass:             oss.Ptr("Standard,IA"),     // Filter by storage class. Separate multiple values with commas.
			},
			Destination: &oss.InventoryDestination{
				OSSBucketDestination: &oss.InventoryOSSBucketDestination{
					Format:    oss.InventoryFormatCSV,                                   // The format of the exported inventory lists.
					AccountId: oss.Ptr(accountId),                                       // Alibaba Cloud account ID. Example: 109885487000****.
					RoleArn:   oss.Ptr("acs:ram::" + accountId + ":role/AliyunOSSRole"), // RAM role ARN. Example: acs:ram::109885487000****:role/ram-test.
					Bucket:    oss.Ptr("acs:oss:::" + bucketName),                       // Destination bucket for inventory lists.
					Prefix:    oss.Ptr("export/"),                                       // Path prefix for inventory list files in the destination bucket.
				},
			},
			Schedule: &oss.InventorySchedule{
				Frequency: oss.InventoryFrequencyDaily, // The frequency at which the inventory list is exported (daily).
			},
			IncludedObjectVersions: oss.Ptr("All"), // Specify whether to include all versions of objects or only the current versions of objects in the inventory list.
		},
	}

	result, err := client.PutBucketInventory(context.TODO(), request)
	if err != nil {
		log.Fatalf("failed to put bucket inventory %v", err)
	}

	log.Printf("put bucket inventory result: %#v\n", result)
}

Use DeleteBucketInventoryRequest to delete a specific inventory configuration by name.

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
)

func init() {
	flag.StringVar(&region, "region", "", "The region where the bucket is located.")
	flag.StringVar(&bucketName, "bucket", "", "The bucket name.")
}

func main() {
	flag.Parse()

	var inventoryId = "inventory id"

	if len(bucketName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, bucket name required")
	}

	if len(region) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, region required")
	}

	cfg := oss.LoadDefaultConfig().
		WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
		WithRegion(region)

	client := oss.NewClient(cfg)

	request := &oss.DeleteBucketInventoryRequest{
		Bucket:      oss.Ptr(bucketName),
		InventoryId: oss.Ptr(inventoryId),
	}

	result, err := client.DeleteBucketInventory(context.TODO(), request)
	if err != nil {
		log.Fatalf("failed to delete bucket inventory %v", err)
	}

	log.Printf("delete bucket inventory result: %#v\n", result)
}