29得票4回答
将map[string]DynamoDBAttributeValue反序列化为结构体

我正在尝试使用aws-sdk-go设置AWS Lambda,每当在特定dynamodb表中添加新的user时触发。 一切都运行得很好,但我找不到一种方法来解组类似于:map[string]DynamoDBAttributeValue的映射。 { "name": { ...

26得票3回答
如何只使用分区键从AWS DynamoDB获取数据?

我正在使用aws-sdk-go库来连接Golang中的DynamoDb数据库。我的DynamoDb表具有分区键DeviceId(字符串)和排序键Time(数字)。我该如何编写GetItemInput以获取特定DeviceId的所有数据?params := &dynamodb.GetIt...

21得票6回答
如何使用变量中的凭据运行AWS SDK?

我之前使用环境变量,效果很好。 现在我正在将我的配置变量迁移到一个单独的文件中,我有 AWS_SECRET_ACCESS_KEY 和 AWS_ACCESS_KEY_ID 变量,它们包含从该文件加载的相应值。 我尝试了这段代码但是出现了错误:creds := credentials.NewS...

14得票5回答
如何在AWS Lambda中使用Golang支持多个触发器?

我正在使用Golang构建一个AWS Lambda函数,用于将n到m个S3存储桶中的内容复制。有一个要求是支持S3触发器以及从SQS获取数据,在那里存储了所有源S3存储桶的更改。代码可以在这里找到:https://github.com/maknahar/s3copy 我尝试了以下方法:fun...

12得票2回答
在Go代码中无法获取AWS EKS集群的kubeconfig

我创建了一个AWS EKS集群。为了获取其kubeconfig,我通常会在shell中运行aws eks update-kubeconfig --name cluster-name --region us-west-2。然而,我现在希望在Go语言中获取kubeconfig而无需在shell中运...

10得票2回答
如何使用变量中的凭证来运行 AWS SDK 版本 2?

我的问题与这个问题相同:如何使用变量中的凭据运行AWS SDK?,但我正在使用不再使用Session的SDK版本2(如果我理解正确的话)。因此,我正在创建一个新客户端,并且我有凭据作为变量。 我需要使用IAM服务。以下是函数:func getIAMClient(ctx context.Cont...

10得票1回答
如何在S3中保存数据流? aws-sdk-go示例无法工作?

我想将给定的数据流持久化到一个S3兼容的存储中。 在数据流结束之前无法确定其大小,大小可能会从5MB变化到大约500GB。 我尝试了不同的方法,但没有找到比自己实现分片更好的解决方案。我的最佳猜测是创建一个固定大小的缓冲区,将其填满我的数据流并将其写入S3中。 是否有更好的解决方案?也许有...

9得票1回答
无法将字符串类型的"LATEST"用作字段值中的*字符串类型。

我正在尝试使用新的aws-sdk-go(v2)运行ECS任务。我在初始化&ecs.RunTaskInput{}结构时遇到了一些问题。 根据文件,这是结构定义: type RunTaskInput struct { _ struct{} `type:"structure"` ...

9得票1回答
使用Golang-AWS-SDK IoTDataPlane进行HTTP POST到AWS IoT

我希望能够通过AWS-SDK和HTTP在golang中使用AWS IoT向MQTT主题发送消息,但是尝试使用以下代码时失败了。响应如下: ResourceNotFoundException: Not Found status code: 404, request id: 3d2c0f11-0...

9得票2回答
如何使用aws-sdk-go强制删除S3桶中所有对象的所有版本,然后最终删除整个桶?

我有一个启用版本控制的S3存储桶,其中包含几个文件并具有版本。我编写了一个示例Golang程序,可以执行以下操作: GetBucketVersioning - 它能够获取存储桶版本控制状态,即已启用 ListObjects - 它能够列出存储桶对象 DeleteObjects - 它能够删...