Object Storage Service:オブジェクト一覧表示

次のコードは、操作の詳細を示しています。

type ListObjectsV2Paginator struct

func (p *ListObjectsV2Paginator) HasNext() bool

func (p *ListObjectsV2Paginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*ListObjectsV2Result, error)

func (c *Client) NewListObjectsV2Paginator(request *ListObjectsV2Request, optFns ...func(*PaginatorOptions)) *ListObjectsV2Paginator

リクエストパラメータ

次の表は、ListObjectsV2 の共通パラメーターについて説明しています。

レスポンスパラメータ

func (c *Client) ListObjectsV2(ctx context.Context, request *ListObjectsV2Request, optFns ...func(*Options)) (*ListObjectsV2Result, error)

リクエストパラメータ

レスポンスパラメータ

次のコードは、ページネータを使用してバケット内のすべてのオブジェクトを一覧表示する方法を示しています。

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(&region, "region", "", "バケットが配置されているリージョン。")
	flag.StringVar(&bucketName, "bucket", "", "バケットの`名前`。")
}

func main() {
	// コマンドラインパラメータを解析します。
	flag.Parse()

	// バケットの名前が指定されているかどうかを確認します。
	if len(bucketName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("無効なパラメータ、バケット名が必要です")
	}

	// リージョンが指定されているかどうかを確認します。
	if len(region) == 0 {
		flag.PrintDefaults()
		log.Fatalf("無効なパラメータ、リージョンが必要です")
	}

	// デフォルトの構成を読み込み、認証情報プロバイダとリージョンを指定します。
	cfg := oss.LoadDefaultConfig().
		WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
		WithRegion(region)

	// OSS クライアントを作成します。
	client := oss.NewClient(cfg)

	// オブジェクトを一覧表示するためのリクエストを作成します。
	request := &oss.ListObjectsV2Request{
		Bucket: oss.Ptr(bucketName),
	}

	// ページネータを作成します。
	p := client.NewListObjectsV2Paginator(request)

	// ページ番号カウンタを初期化します。
	var i int
	log.Println("オブジェクト:")

	// ページネータの各ページをトラバースします。
	for p.HasNext() {
		i++

		// 次のページのデータを取得します。
		page, err := p.NextPage(context.TODO())
		if err != nil {
			log.Fatalf("ページ %v の取得に失敗しました、%v", i, err)
		}

		// ページ上の各オブジェクトに関する情報を表示します。
		for _, obj := range page.Contents {
			log.Printf("オブジェクト:%v, %v, %v\n", oss.ToString(obj.Key), obj.Size, oss.ToTime(obj.LastModified))
		}
	}
}

次のコードは、ListObjectsV2 操作を呼び出すことによってバケット内のすべてのオブジェクトを一覧表示する方法を示しています。

package main

import (
	"context"
	"flag"
	"log"
	"time"

	"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(&region, "region", "", "バケットが配置されているリージョン。")
	flag.StringVar(&bucketName, "bucket", "", "バケットの`名前`。")
}

func main() {
	flag.Parse() // コマンドラインパラメータを解析します。

	// バケットの名前が指定されているかどうかを確認します。
	if len(bucketName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("無効なパラメータ、バケット名が必要です")
	}

	// リージョンが指定されているかどうかを確認します。
	if len(region) == 0 {
		flag.PrintDefaults()
		log.Fatalf("無効なパラメータ、リージョンが必要です")
	}

	// デフォルトの構成を読み込み、認証情報プロバイダとリージョンを指定します。
	cfg := oss.LoadDefaultConfig().
		WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
		WithRegion(region)

	// OSS クライアントを作成します。
	client := oss.NewClient(cfg) 

	// ListObjectsV2 リクエストを作成します。
	request := &oss.ListObjectsV2Request{
		Bucket:            oss.Ptr(bucketName),
	}

	for {
		// すべてのオブジェクトを一覧表示する操作を実行します。
		lsRes, err := client.ListObjectsV2(context.TODO(), request)
		if err != nil {
			log.Fatalf("オブジェクトの一覧表示に失敗しました: %v", err)
		}

		// 結果を表示します。
		for _, object := range lsRes.Contents {
			log.Printf("オブジェクトキー: %s, タイプ: %s, サイズ: %d, ETag: %s, 最終更新日: %s, ストレージクラス: %s\n",
				*object.Key, *object.Type, object.Size, *object.ETag, object.LastModified.Format(time.RFC3339), *object.StorageClass)
		}

		// 一覧表示するオブジェクトがさらに存在する場合、continueToken パラメータの値を更新して残りの結果を取得します。
		if lsRes.IsTruncated {
			request.ContinuationToken = lsRes.NextContinuationToken
		} else {
			break // オブジェクトがもう存在しない場合はサイクルを終了します。
		}
	}

	log.Println("すべてのオブジェクトが一覧表示されました。")
}

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(&region, "region", "", "バケットが配置されているリージョン。")
	flag.StringVar(&bucketName, "bucket", "", "バケットの`名前`。")
}

func main() {
	flag.Parse() // コマンドラインパラメータを解析します。

	// バケット名が指定されているかどうかを確認します。
	if len(bucketName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("無効なパラメータ、バケット名が必要です")
	}

	// リージョンが指定されているかどうかを確認します。
	if len(region) == 0 {
		flag.PrintDefaults()
		log.Fatalf("無効なパラメータ、リージョンが必要です")
	}

	// デフォルトの構成を読み込み、認証情報プロバイダとリージョンを指定します。
	cfg := oss.LoadDefaultConfig().
		WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
		WithRegion(region)

	// OSSClient インスタンスを作成します。
	client := oss.NewClient(cfg)

	// ListObjectsV2 リクエストを作成し、デリミタをスラッシュ (/) に設定します。
	request := &oss.ListObjectsV2Request{
		Bucket:            oss.Ptr(bucketName),
		Delimiter:         oss.Ptr("/"), // スラッシュ (/) をデリミタとして使用します。
		MaxKeys:           100,          // リクエストごとに返されるオブジェクトの最大数。
	}

	// すべてのサブディレクトリ (CommonPrefixes) を格納する変数。
	var subdirectories []oss.CommonPrefix

	for {
		lsRes, err := client.ListObjectsV2(context.TODO(), request)
		if err != nil {
			log.Fatalf("オブジェクトの一覧表示に失敗しました: %v", err)
		}

		// サブディレクトリ (CommonPrefixes) をログに記録し、収集します。
		for _, prefix := range lsRes.CommonPrefixes {
			log.Printf("サブディレクトリ: %v\n", *prefix.Prefix)
			subdirectories = append(subdirectories, prefix)
		}

		// 一覧表示するオブジェクトがさらに存在する場合、continueToken パラメータの値を更新して残りの結果を取得します。
		if lsRes.IsTruncated {
			request.ContinuationToken = lsRes.NextContinuationToken
		} else {
			break // オブジェクトがもう存在しない場合はサイクルを終了します。
		}
	}

	log.Println("すべてのサブディレクトリが一覧表示されました。")
	log.Printf("サブディレクトリの合計数: %d\n", len(subdirectories))
}