哈喽!今天心血来潮给大家带来了《如何将 s3EventRecord 从 AWS SNS 转换为地图 (Go)》,想必大家应该对Golang都不陌生吧,那么阅读本文就都不会很困难,以下内容主要涉及到,若是你正在学习Golang,千万别错过这篇文章~希望能帮助到你!
问题内容我的数据流如下:
- 文件已上传到 s3 存储桶
- s3 存储桶触发 sns 主题
- sns 主题将 s3 事件作为消息传递给 lambda
- lambda 由 sns 触发并尝试读取 record.sns.message
- 我尝试将消息(转义的 json)转换为映射以便于解析。
我尝试像 strconv.unquote 那样做,但这没有用。如何解组该字符串?这是我的相关代码:
func Handler(request events.SNSEvent) {
for _, record := range request.Records {
message := record.SNS.Message
x := make(map[string]string)
jsonErr := json.Unmarshal([]byte(message),&x)
if jsonErr!=nil {
logger.Errorf("Welp couldn't convert json to a map %s",jsonErr.Error())
}
解决方案
实际上,该结构存在于 github.com/aws/aws-lambda-go/events
中。使用 s3event
结构,而不是解组到映射中。
这就是我的使用方式:
for _, snsEventRecord := range event.Records {
var s3Event events.S3Event
err = json.Unmarshal([]byte(snsEventRecord.SNS.Message), &s3Event)
if err != nil {
return err
}
for _, s3EventRecord := range s3Event.Records {
fmt.Println(s3EventRecord.S3.Object.Key)
}
今天带大家了解了的相关知识,希望对你有所帮助;关于Golang的技术知识我们会一点点深入介绍,欢迎大家关注编程网公众号,一起学习编程~