如何使用 GoLang 将结构体或对象上传至 S3 存储桶？

本篇文章向大家介绍《如何使用 GoLang 将结构体或对象上传至 S3 存储桶？》，主要包括，具有一定的参考价值，需要的朋友可以参考一下。

我正在 golang 中使用 aws s3 sdk，尝试上传和下载到各种存储桶。我想知道是否有更简单的方法将结构或对象直接上传到存储桶？

我有一个代表事件的结构：

type event struct {
    id               string
    processid        string                 
    txnid            string
    inputs           map[string]interface{}                      
}

我想上传到 s3 存储桶中。但我在文档中找到的代码仅适用于上传字符串。

func save(client s3client, t interface{}, key string) bool {
    svc := client.s3clientobject
    input := &s3.putobjectinput{
        body: aws.readseekcloser(strings.newreader("testing this one")),
        bucket: aws.string(gets3bucket()),
        key: aws.string(getobjectkey(t, key)),
        metadata: map[string]*string{
            "metadata1": aws.string("value1"),
            "metadata2": aws.string("value2"),
        },

    }

这成功地将基本文件上传到 s3 存储桶，打开该存储桶时只会显示“测试此文件”。有没有办法上传到存储桶，以便它上传一个对象而不仅仅是一个字符串值？

感谢任何帮助，因为我是 go 和 s3 的新手。

编辑

这是我用于 get 函数的代码：

func getit(client s3client, t interface{}, key string) interface{} {
    svc := client.s3clientobject
    s3key := getobjectkey(t, key)
    resp, err := svc.getobject(&s3.getobjectinput{
        bucket: aws.string(gets3bucket()),
        key: aws.string(s3key),
    })
    if err != nil {
        fmt.println(err)
        return err
    }    
    result := json.newdecoder(resp.body).decode(&t)
    fmt.println(result) 
    return json.newdecoder(resp.body).decode(&t)
}

func main() {
    client := b.CreateS3Client()
    event := b.CreateEvent()
    GetIt(client, event, key)
}

正确答案

将值编码为字节并上传字节。以下是将值编码为 json 字节的方法：

func save(client s3client, value interface{}, key string) error {

    p, err := json.marshal(value)
    if err != nil {
        return err
    }
    input := &s3.putobjectinput{
        body:   aws.readseekcloser(bytes.newreader(p)),
        …
    }
    …
}

使用您要上传的值调用“保存”：

value := &event{id: "an id", …}
err := save(…, value, …)
if err != nil {
  // handle error
}

可能的编码格式有很多，包括 gob、xml 和 json、msgpack 等。最佳编码格式将取决于您的应用程序要求。

获取对象时相反的过程：

func getit(client s3client, t interface{}, key string) error {
    svc := client.s3clientobject
    resp, err := svc.getobject(&s3.getobjectinput{
        bucket: aws.string(gets3bucket()),
        key: aws.string(key),
    })
    if err != nil {
        return err
    }    
    return json.newdecoder(resp.body).decode(t)
}

使用指向目标值的指针调用 getit：

var value model.event
err := getit(client, &value, key)
if err != nil {
    // handle error
}
fmt.println(value) // prints the decoded value.

此处引用的示例表明，s3 允许您上传实现 io.Reader 接口的任何内容。该示例使用 strings.newreader 语法创建一个 io.reader ，它知道如何向调用者提供指定的字符串。您的工作（根据 aws 此处）是弄清楚如何调整您需要存储到 io.reader 中的任何内容。

您可以像这样直接存储 json 编码的字节

package main

import (
    "bytes"
    "encoding/json"
)

type Event struct {
    ID               string
    ProcessID        string
    TxnID            string
    Inputs           map[string]interface{}
}

func main() {
    // To prepare the object for writing
    b, err := json.Marshal(event)
    if err != nil {
        return
    }
    // pass this reader into aws.ReadSeekCloser(...)
    reader := bytes.NewReader(b)
}

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