当前位置： > > > > Go AWS S3 SDK：获取具有特定键/值标签的存储桶的最佳方式

Go AWS S3 SDK：获取具有特定键/值标签的存储桶的最佳方式

来源：stackoverflow
2024-04-27 22:24:35
0浏览
收藏

学习知识要善于思考，思考，再思考！今天米云小编就给大家带来《Go AWS S3 SDK：获取具有特定键/值标签的存储桶的最佳方式》，以下内容主要包含等知识点，如果你正在学习或准备学习Golang，就都不要错过本文啦~让我们一起来看看吧，能帮助到你就更好了！

问题内容

我有一个函数，可以提取用特定键和值标记的所有 aws s3 存储桶。 这种方法不是最佳的。它循环遍历所有桶并调用 每个 s3svc.getbuckettagging。所以时间复杂度是n+1。你们知道更好的方法吗？

func (p *awsS3Provisioner) GetBucketsTaggedWith(tag *s3.Tag) ([]*s3.Bucket, error) {

    result, err := p.s3svc.ListBuckets(&s3.ListBucketsInput{})
    if err != nil {
        return nil, err
    }

    matchedBuckets := []*s3.Bucket{}
    if result != nil && result.Buckets != nil && len(result.Buckets) > 1 {
        for _, bucket := range result.Buckets {
            bucketInput := &s3.GetBucketTaggingInput{Bucket: bucket.Name}
            bucketOutput, err := p.s3svc.GetBucketTagging(bucketInput)
            if err != nil {
                continue
            }
            if bucketOutput != nil && bucketOutput.TagSet != nil && len(bucketOutput.TagSet) > 0 {
                for _, bucketTag := range bucketOutput.TagSet {
                    if *bucketTag.Key == *tag.Key && *bucketTag.Value == *tag.Value {
                        matchedBuckets = append(matchedBuckets, bucket)
                    }
                }
            }
        }
    }
    return matchedBuckets, nil
}

谢谢 二看

正确答案

您需要使用“资源组标记 api”来实现此目的。

我在示例中使用适用于 go v2 的 aws 开发工具包。不幸的是，由于目前有 ，我需要提供两个版本。

我的示例返回具有标签 owner=luke skywalker 的所有 s3 存储桶。

由于错误，我们需要取消分页。我在代码中添加了注释，如果错误得到修复，则不需要该注释。

package main

import (
    "context"
    "fmt"
    "github.com/aws/aws-sdk-go-v2/aws"
    "github.com/aws/aws-sdk-go-v2/config"
    "github.com/aws/aws-sdk-go-v2/service/resourcegroupstaggingapi"
    "github.com/aws/aws-sdk-go-v2/service/resourcegroupstaggingapi/types"
    "os"
)

func main() {
    cfg, err := config.LoadDefaultConfig(context.TODO())
    if err != nil {
        fmt.Printf("unable to create config: %v\n", err)
        os.Exit(1)
    }

    client := resourcegroupstaggingapi.NewFromConfig(cfg)

    params := resourcegroupstaggingapi.GetResourcesInput{
        ResourceTypeFilters: []string{"s3"},
        TagFilters: []types.TagFilter{
            {
                Key:    aws.String("Owner"),
                Values: []string{"Luke Skywalker"},
            },
        },
    }

    paginator := resourcegroupstaggingapi.NewGetResourcesPaginator(client, &params)

    for paginator.HasMorePages() {
        page, err := paginator.NextPage(context.TODO())
        if err != nil {
            fmt.Printf("unable to read next page: %v\n", err)
            continue
        }

        for _, t := range page.ResourceTagMappingList {
            fmt.Printf("arn: %s\n", *t.ResourceARN)
        }

        // Until the bug (see link below is fixed), we need to do this for the paginator:
        // https://github.com/aws/aws-sdk-go-v2/issues/1201
        if *page.PaginationToken == "" || page.PaginationToken == nil {
            break
        }
    }
}

本篇关于《Go AWS S3 SDK：获取具有特定键/值标签的存储桶的最佳方式》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于Golang的相关知识，请关注米云公众号！