结合使用 aws-sdk-go-v2 和 localstack 的方法

偷偷努力，悄无声息地变强，然后惊艳所有人！哈哈，小伙伴们又来学习啦~今天我将给大家介绍《结合使用 aws-sdk-go-v2 和 localstack 的方法》，这篇文章主要会讲到等等知识点，不知道大家对其都有多少了解，下面我们就一起来看一吧！当然，非常希望大家能多多评论，给出合理的建议，我们一起学习，一起进步！

我正在尝试从 aws-sdk-go 迁移到 aws-sdk-go-v2。但是，我在本地使用 localstack 来模仿一些 aws 服务，例如 sqs 和 s3。我不确定如何配置新的 sdk 以使用 localstack 端点而不是真实的端点。

例如，在 v1 sdk 中，我可以通过在此处设置端点将其指向 localstack：

session.Must(session.NewSession(&aws.Config{
    Region:   aws.String("us-east-1"),
    Endpoint: aws.String("http://localstack:4566"), 
}))

但是，我该如何在 v2 sdk 中执行此操作？我认为我需要在 config 中设置一些参数，但我没有看到任何指定端点的选项。

解决方案

这取决于您使用的服务。

为了初始化 glue 客户端：

cfg, err := config.loaddefaultconfig(context.background())
if err != nil {
    panic(err)
}
glueconnection := glue.new(glue.options{credentials: cfg.credentials, region: cfg.region})

因此，如果您仔细研究 python 代码，主要是这个，您会看到：

https://github.com/localstack/localstack/blob/25ba1de8a8841af27feab54b8d55c80ac46349e2/localstack/services/edge.py#L115

然后，在使用 v2 aws golang sdk 时，我需要覆盖授权标头，以便添加正确的结构。

我通过运行 aws cli 工具并跟踪记录 localstack docker 容器来获取结构：

'authorization': 'aws4-hmac-sha256 credential=akiar2x5nrnsrtcojhci/20210827/eu-west-1/sns/aws4_request, signedheaders=content-type;host;x-amz-date, signature=c69672d38631752ede15d90e7047a5183ebf3707a228decf6ec26e97fdbd02aa',

在 go 中，我需要覆盖 http 客户端以添加该标头：

type s struct {
    cl http.Client
}

func (s s) Do(r *http.Request) (*http.Response, error) {
    r.Header.Add("authorization", "AWS4-HMAC-SHA256 Credential=AKIAR2X5NRNSRTCOJHCI/20210827/eu-west-1/sns/aws4_request, SignedHeaders=content-type;host;x-amz-date, Signature=33fa777a3bb1241f30742419b8fab81945aa219050da6e29b34db16053661000")
    return s.cl.Do(r)
}

func NewSNS(endpoint, topicARN string) (awsPubSub, error) {
    cfg := aws.Config{
        EndpointResolver: aws.EndpointResolverFunc(func(service, region string) (aws.Endpoint, error) {
            return aws.Endpoint{
                PartitionID:       "aws",
                URL:               "http://localhost:4566",
                SigningRegion:     "eu-west-1",
                HostnameImmutable: true,
                // Source:        aws.EndpointSourceCustom,
            }, nil
        }),
        HTTPClient: s{http.Client{}},
    }

....

这非常耗时且痛苦，我很想知道更好的方法，但这暂时有效......

今天带大家了解了的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~