登录
首页 >  Golang >  Go问答

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

来源:stackoverflow

时间:2024-04-27 22:24:35 257浏览 收藏

学习知识要善于思考,思考,再思考!今天golang学习网小编就给大家带来《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 开发工具包。不幸的是,由于目前有 bug in the paginators,我需要提供两个版本。

我的示例返回具有标签 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, ¶ms)

    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的相关知识,请关注golang学习网公众号!

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>