本文介绍如何通过 ListObjectsType2 列举指定桶下的所有对象、指定前缀文件、指定目录下的文件和子目录。

注意事项 #

• ListObjects 接口已经修订为 ListObjectsType2，强烈建议开发者使用 ListObjectsType2。为保障向后兼容性，TOS 继续支持 ListObjects 接口。
• 使用列举对象 V2，您必须具有 tos:ListBucket 权限，具体操作，请参见 IAM 策略概述。

参数说明 #

ListObjectsType2 支持的参数如下:

示例代码 #

简单列举 #

以下代码用于列举指定存储桶获取最多 10 个对象。

package main

import (
   "context"
   "fmt"

   "github.com/volcengine/ve-tos-golang-sdk/v2/tos"
)

func checkErr(err error) {
   if err != nil {
      if serverErr, ok := err.(*tos.TosServerError); ok {
         fmt.Println("Error:", serverErr.Error())
         fmt.Println("Request ID:", serverErr.RequestID)
         fmt.Println("Response Status Code:", serverErr.StatusCode)
         fmt.Println("Response Header:", serverErr.Header)
         fmt.Println("Response Err Code:", serverErr.Code)
         fmt.Println("Response Err Msg:", serverErr.Message)
      } else if clientErr, ok := err.(*tos.TosClientError); ok {
         fmt.Println("Error:", clientErr.Error())
         fmt.Println("Client Cause Err:", clientErr.Cause.Error())
      } else {
         fmt.Println("Error:", err)
      }
      panic(err)
   }
}

func main() {
   var (
      accessKey = os.Getenv("TOS_ACCESS_KEY")
      secretKey = os.Getenv("TOS_SECRET_KEY")
      // Bucket 对应的 Endpoint，以华北2（北京）为例：https://tos-cn-beijing.volces.com
      endpoint = "https://tos-cn-beijing.volces.com"
      region   = "cn-beijing"
      // 填写 BucketName
      bucketName = "*** Provide your bucket name ***"

      ctx = context.Background()
   )
   // 初始化客户端
   client, err := tos.NewClientV2(endpoint, tos.WithRegion(region), tos.WithCredentials(tos.NewStaticCredentials(accessKey, secretKey)))
   checkErr(err)
   // 获取 bucket 中最多 10 个对象
   output, err := client.ListObjectsType2(ctx, &tos.ListObjectsType2Input{
      Bucket:  bucketName,
      MaxKeys: 10,
   })
   checkErr(err)
   for _, obj := range output.Contents {
      // 对象 Key
      fmt.Println("Object Key:", obj.Key)
      // 对象最后修改时间
      fmt.Println("Object LastModified:", obj.LastModified)
      // 对象 Etag
      fmt.Println("Object ETag:", obj.ETag)
      // 对象大小
      fmt.Println("Object Size:", obj.Size)
      // 对象 Owner
      fmt.Println("Object Owner:", obj.Owner)
      // 对象存储类型
      fmt.Println("Object StorageClass:", obj.StorageClass)
      // 对象 CRC64
      fmt.Println("Object HashCrc64ecma:", obj.HashCrc64ecma)
   }

}

分页列举 #

以下代码用于分页列举指定存储桶中的对象。

package main

import (
   "context"
   "fmt"

   "github.com/volcengine/ve-tos-golang-sdk/v2/tos"
)

func checkErr(err error) {
   if err != nil {
      if serverErr, ok := err.(*tos.TosServerError); ok {
         fmt.Println("Error:", serverErr.Error())
         fmt.Println("Request ID:", serverErr.RequestID)
         fmt.Println("Response Status Code:", serverErr.StatusCode)
         fmt.Println("Response Header:", serverErr.Header)
         fmt.Println("Response Err Code:", serverErr.Code)
         fmt.Println("Response Err Msg:", serverErr.Message)
      } else if clientErr, ok := err.(*tos.TosClientError); ok {
         fmt.Println("Error:", clientErr.Error())
         fmt.Println("Client Cause Err:", clientErr.Cause.Error())
      } else {
         fmt.Println("Error:", err)
      }
      panic(err)
   }
}

func printObjectContent(contents []tos.ListedObjectV2) {
   for _, obj := range contents {
      // 对象 Key
      fmt.Println("Object Key:", obj.Key)
      // 对象最后修改时间
      fmt.Println("Object LastModified:", obj.LastModified)
      // 对象 Etag
      fmt.Println("Object ETag:", obj.ETag)
      // 对象大小
      fmt.Println("Object Size:", obj.Size)
      // 对象 Owner
      fmt.Println("Object Owner:", obj.Owner)
      // 对象存储类型
      fmt.Println("Object StorageClass:", obj.StorageClass)
      // 对象 CRC64
      fmt.Println("Object HashCrc64ecma:", obj.HashCrc64ecma)
   }
}

func main() {
   var (
      accessKey = os.Getenv("TOS_ACCESS_KEY")
      secretKey = os.Getenv("TOS_SECRET_KEY")
      // Bucket 对应的 Endpoint，以华北2（北京）为例：https://tos-cn-beijing.volces.com
      endpoint = "https://tos-cn-beijing.volces.com"
      region   = "cn-beijing"
      // 填写 BucketName
      bucketName = "*** Provide your bucket name ***"

      ctx = context.Background()
   )
   // 初始化客户端
   client, err := tos.NewClientV2(endpoint, tos.WithRegion(region), tos.WithCredentials(tos.NewStaticCredentials(accessKey, secretKey)))
   checkErr(err)
   // 获取 bucket 中前 1000 个对象
   output, err := client.ListObjectsType2(ctx, &tos.ListObjectsType2Input{
      Bucket:  bucketName,
      MaxKeys: 1000,
   })
   checkErr(err)
   printObjectContent(output.Contents)

   // 分页列举后 1000 个对象
   output, err = client.ListObjectsType2(ctx, &tos.ListObjectsType2Input{
      Bucket:            bucketName,
      MaxKeys:           1000,
      ContinuationToken: output.NextContinuationToken,
   })
   printObjectContent(output.Contents)

}

列举指定前缀的所有对象 #

以下代码用于列举指定存储桶指定前缀的所有对象。

package main

import (
   "context"
   "fmt"

   "github.com/volcengine/ve-tos-golang-sdk/v2/tos"
)

func checkErr(err error) {
   if err != nil {
      if serverErr, ok := err.(*tos.TosServerError); ok {
         fmt.Println("Error:", serverErr.Error())
         fmt.Println("Request ID:", serverErr.RequestID)
         fmt.Println("Response Status Code:", serverErr.StatusCode)
         fmt.Println("Response Header:", serverErr.Header)
         fmt.Println("Response Err Code:", serverErr.Code)
         fmt.Println("Response Err Msg:", serverErr.Message)
      } else if clientErr, ok := err.(*tos.TosClientError); ok {
         fmt.Println("Error:", clientErr.Error())
         fmt.Println("Client Cause Err:", clientErr.Cause.Error())
      } else {
         fmt.Println("Error:", err)
      }
      panic(err)
   }
}

func main() {
   var (
      accessKey = os.Getenv("TOS_ACCESS_KEY")
      secretKey = os.Getenv("TOS_SECRET_KEY")
      // Bucket 对应的 Endpoint，以华北2（北京）为例：https://tos-cn-beijing.volces.com
      endpoint = "https://tos-cn-beijing.volces.com"
      region   = "cn-beijing"
      // 填写 BucketName
      bucketName = "*** Provide your bucket name ***"
      prefix     = "*** Provide your object key prefix ***"

      ctx = context.Background()
   )
   // 初始化客户端
   client, err := tos.NewClientV2(endpoint, tos.WithRegion(region), tos.WithCredentials(tos.NewStaticCredentials(accessKey, secretKey)))
   checkErr(err)
   // 列举指定前缀下的所有对象
   truncated := true
   continuationToken := ""
   for truncated {

      output, err := client.ListObjectsType2(ctx, &tos.ListObjectsType2Input{
         Bucket:            bucketName,
         MaxKeys:           1000,
         ContinuationToken: continuationToken,
         Prefix:            prefix,
      })
      checkErr(err)
      for _, obj := range output.Contents {
         // 对象 Key
         fmt.Println("Object Key:", obj.Key)
         // 对象最后修改时间
         fmt.Println("Object LastModified:", obj.LastModified)
         // 对象 Etag
         fmt.Println("Object ETag:", obj.ETag)
         // 对象大小
         fmt.Println("Object Size:", obj.Size)
         // 对象 Owner
         fmt.Println("Object Owner:", obj.Owner)
         // 对象存储类型
         fmt.Println("Object StorageClass:", obj.StorageClass)
         // 对象 CRC64
         fmt.Println("Object HashCrc64ecma:", obj.HashCrc64ecma)
      }
      truncated = output.IsTruncated
      continuationToken = output.NextContinuationToken
   }

}