使用GoLang将struct或对象上传到S3存储桶的实现方法咨询

第一步：修改上传Save函数 #

要把结构体存入S3，本质是先将结构体序列化为可存储的字节流，你下载时用的是JSON解析，上传对应序列化为JSON格式即可，修改你的Save函数逻辑如下：

import "encoding/json"
import "bytes"

func Save(client S3Client, T interface{}, key string) bool {
    svc := client.S3clientObject
    // 先将结构体序列化为JSON字节
    jsonBytes, err := json.Marshal(T)
    if err != nil {
        fmt.Println("结构体序列化失败：", err)
        return false
    }
    input := &s3.PutObjectInput{
        // 把JSON字节包装成Reader传入
        Body: aws.ReadSeekCloser(bytes.NewReader(jsonBytes)),
        Bucket: aws.String(GetS3Bucket()),
        Key: aws.String(GetObjectKey(T, key)),
        Metadata: map[string]*string{
            "metadata1": aws.String("value1"),
            "metadata2": aws.String("value2"),
        },
        // 可选配置：加上Content-Type方便后续识别文件格式
        ContentType: aws.String("application/json"),
    }
    // 保留原有PutObject调用逻辑即可
    _, err = svc.PutObject(input)
    if err != nil {
        fmt.Println("上传S3失败：", err)
        return false
    }
    return true
}

第二步：修复现有GetIt函数的问题 #

你当前的GetIt函数存在两个明显错误，会导致无法正确读取结构体：

1. 对resp.Body做了两次Decode操作，流在第一次读取后就已经被消费完，第二次读取会直接返回EOF错误
2. 传入的参数T必须是指针类型，否则Decode修改的只是形参副本，不会生效到外部传入的原变量

修改后的GetIt函数如下：

func GetIt(client S3Client, T interface{}, key string) error {
    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("获取S3对象失败：", err)
        return err
    }
    defer resp.Body.Close() // 必须加，避免资源泄漏
    // 仅做一次Decode，直接修改指针指向的原变量
    err = json.NewDecoder(resp.Body).Decode(T)
    if err != nil {
        fmt.Println("JSON解析失败：", err)
    }
    return err
}

第三步：调整调用逻辑 #

调用GetIt时要传入结构体的指针，不要传值：

func main() {
    client := b.CreateS3Client()
    event := b.CreateEvent()
    // 测试上传
    saveOk := Save(client, event, "你的自定义key")
    fmt.Println("上传结果：", saveOk)
    // 测试下载，必须传结构体指针
    var getEvent Event
    err := GetIt(client, &getEvent, "你的自定义key")
    if err != nil {
        fmt.Println("下载失败：", err)
        return
    }
    fmt.Println("下载到的事件数据：", getEvent)
}

注意事项 #

• 需要序列化的结构体字段必须首字母大写（公开字段），小写的私有字段会被json.Marshal自动忽略，不会被存入S3
• 如果不想用JSON格式存储，也可以换成gob、protobuf等其他序列化方式，只要保证上传、下载的序列化/反序列化规则一致即可

内容的提问来源于stack exchange，提问作者user16158841