AWS SDK Go V2 中 PutObject API 报错，访问被拒绝

大家好，我们又见面了啊~本文《AWS SDK Go V2 中 PutObject API 报错，访问被拒绝》的内容中将会涉及到等等。如果你正在学习Golang相关知识，欢迎关注我，以后会给大家带来更多Golang相关文章，希望我们能一起进步！下面就开始本文的正式内容~

在我们的暂存环境中，我们可以无凭据访问我们的私有 s3 存储桶。访问权限被授予单个 docker 容器。我尝试使用 aws-sdk-go-v2 sdk 库使用 putobject 上传文件，但不断收到 403 accessdenied api 错误。

我的上传代码如下所示：

var uploadFileFunc = func(s3Details S3Details, key string, payload []byte, params MetadataParams) (*s3.PutObjectOutput, error) {
    client := getS3Client(s3Details)

    return client.PutObject(context.TODO(), &s3.PutObjectInput{
        Bucket:      aws.String(s3Details.Bucket),
        Key:         aws.String(key),
        Body:        bytes.NewReader(payload),
        ContentType: aws.String("text/xml"),
    })
}

func getS3Client(s3Details S3Details) *s3.Client {
    endpointResolver := aws.EndpointResolverWithOptionsFunc(func(service, region string, options ...interface{}) (aws.Endpoint, error) {
        if s3Details.EndpointUrl != "" {
            return aws.Endpoint{
                PartitionID:   "aws",
                URL:           s3Details.EndpointUrl,
                SigningRegion: s3Details.Region,
                SigningMethod: s3Details.SignatureVersion,
            }, nil
        }
        return aws.Endpoint{}, &aws.EndpointNotFoundError{}
    })

    cfg, _ := config.LoadDefaultConfig(context.TODO(),
        config.WithEndpointDiscovery(aws.EndpointDiscoveryEnabled),
        config.WithEndpointResolverWithOptions(endpointResolver))

    return s3.NewFromConfig(cfg, func(o *s3.Options) {
        o.Region = s3Details.Region
        o.Credentials = aws.AnonymousCredentials{}
        o.UsePathStyle = true
    })
}

我正在使用 aws.anonymouscredentials{} （因为我们的访问是无凭据的），但这仅适用于未签名的请求。我无法将 newstaticcredentialsprovider 与 accesskeyid 和/或 secretaccesskey 的空值一起使用，因为这将在 retrieve() 期间引发 staticcredentialsemptyerror。添加虚拟凭据将引发错误，表明它们未记录在案。我假设这是我的 403 accessdenied 的原因。

如何在不在 go sdk 中提供凭据的情况下签署请求？有可能吗？在 boto3 python 库中，这工作得很好。

正确答案

首先，我强烈建议您使用go的aws sdk v2。我将在这里介绍到目前为止我是如何做到这一点的。
首先，我获取与此代码一起使用的 aws 配置（仅显示相关部分）：

cfg, err := config.loaddefaultconfig(context.todo())
    if err != nil {
        log.fatal(err)
    }

这里使用的包是github.com/aws/aws-sdk-go-v2/config。 然后，我实例化一个 s3client 以用于联系 aws s3 服务：

s3client := s3.newfromconfig(*cfg)

在这里，我们使用这个包 github.com/aws/aws-sdk-go-v2/service/s3。最后，要发布您的对象，您必须运行以下代码：

input := &s3.putobjectinput{
    key:    aws.string("test"),
    bucket: aws.string("test"),
    body:   bytes.newreader([]byte("test")),
    acl:    types.objectcannedaclprivate,
}

if _, err := s3client.putobject(context.todo(), input); err != nil {
    return "", fmt.errorf("fn uploadfile %w", err)
}

此处使用的新包是 github.com/aws/aws-sdk-go-v2/service/s3/types。
该代码是一种简化，但您应该能够实现您所需要的。此外，更新 sdk 版本应该只需要很少的时间，如果您必须使用庞大的代码库，您可以同时依赖它们。
如果这有帮助请告诉我！

编辑

我使用 aws.anonymouscredentials{} 选项更新了我的解决方案。现在，我可以使用这些选项成功地将文件上传到 s3 存储桶中。您可以在下面找到完整的解决方案：

package main

import (
    "bytes"
    "context"
    "crypto/tls"
    "net/http"

    "github.com/aws/aws-sdk-go-v2/aws"
    "github.com/aws/aws-sdk-go-v2/config"
    "github.com/aws/aws-sdk-go-v2/service/s3"
    "github.com/aws/aws-sdk-go-v2/service/s3/types"
)

func GetAwsConfig() (*aws.Config, error) {
    cfg, err := config.LoadDefaultConfig(context.TODO(),
        // config.WithClientLogMode(aws.LogRequestWithBody|aws.LogResponseWithBody),
        config.WithRegion("eu-west-1"),
        config.WithHTTPClient(&http.Client{Transport: &http.Transport{
            TLSClientConfig: &tls.Config{InsecureSkipVerify: true},
        }}),
        config.WithEndpointResolverWithOptions(
            aws.EndpointResolverWithOptionsFunc(func(service, region string, options ...interface{}) (aws.Endpoint, error) {
                return aws.Endpoint{
                    PartitionID:       "aws",
                    URL:               "http://127.0.0.1:4566",
                    SigningRegion:     "eu-west-1",
                    HostnameImmutable: true,
                }, nil
            }),
        ))
    if err != nil {
        return nil, err
    }
    return &cfg, err
}

func main() {
    cfg, _ := GetAwsConfig()
    s3Client := s3.NewFromConfig(*cfg, func(o *s3.Options) {
        o.Credentials = aws.AnonymousCredentials{}
    })

    if _, err := s3Client.PutObject(context.Background(), &s3.PutObjectInput{
        Bucket: aws.String("mybucket"),
        Key:    aws.String("myfile"),
        Body:   bytes.NewReader([]byte("hello")),
        ACL:    types.ObjectCannedACLPrivate,
    }); err != nil {
        panic(err)
    }
}

在运行代码之前，您必须创建存储桶。我使用了以下命令：
aws --endpoint-url=http://localhost:4566 s3 mb s3://mybucket
这样您就可以将文件上传到 mybucket s3 存储桶中。要检查文件是否存在，您可以发出以下命令：
aws --endpoint-url=http://localhost:4566 s3 ls s3://mybucket --recursive --人类可读
希望这有助于解决您的问题！

好了，本文到此结束，带大家了解了《AWS SDK Go V2 中 PutObject API 报错，访问被拒绝》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！