Go语言：将DynamoDB查询结果序列化为JSON并忽略空值

嘿，我碰到过一模一样的问题！DynamoDB返回的AttributeValue结构体自带所有可能的字段（比如B、BOOL、N这些），序列化的时候那些没用到的字段自然就显示为null了，确实会白白增加传输体积。给你两个实用的解决办法：

AWS提供了dynamodbattribute工具包，可以自动把DynamoDB的Item映射到你的自定义Go结构体上，而且只会保留有值的字段。配合JSON的omitempty标签，序列化后就不会出现空值了。

首先定义和你的表结构匹配的结构体：

type Product struct {
    ID    string  `json:"id,omitempty"`
    Name  string  `json:"name,omitempty"`
    Price float64 `json:"price,omitempty"`
    // 这里添加你表中实际存在的其他字段
}

然后修改你的查询代码，替换掉直接序列化out.Items[0]的逻辑：

import (
    "encoding/json"
    "log"
    "github.com/aws/aws-sdk-go/aws"
    "github.com/aws/aws-sdk-go/aws/session"
    "github.com/aws/aws-sdk-go/service/dynamodb"
    "github.com/aws/aws-sdk-go/service/dynamodb/dynamodbattribute"
)

func main() {
    // 创建会话，记得处理错误！
    sess, err := session.NewSession(&aws.Config{Region: aws.String("eu-central-1")})
    if err != nil {
        log.Fatalf("Failed to create session: %v", err)
    }
    dyn := dynamodb.New(sess)

    var limit int64 = 5
    out, err := dyn.Scan(&dynamodb.ScanInput{
        TableName: aws.String("Products"),
        Limit:     &limit,
    })
    if err != nil {
        log.Fatalf("Scan failed: %v", err)
    }

    if len(out.Items) > 0 {
        // 把DynamoDB的Item转换为自定义结构体
        var product Product
        err := dynamodbattribute.UnmarshalMap(out.Items[0], &product)
        if err != nil {
            log.Fatalf("Unmarshal failed: %v", err)
        }

        // 序列化结构体，空值字段会被自动忽略
        b, err := json.Marshal(product)
        if err != nil {
            log.Fatalf("Marshal failed: %v", err)
        }
        fmt.Println(string(b))
    }
}

这个方法既简洁又安全，还能让你的代码更具可读性，是最推荐的方案。

如果不想定义结构体，也可以手动遍历AttributeValue的字段，把所有空值的字段过滤掉再序列化：

import (
    "encoding/json"
    "log"
    "github.com/aws/aws-sdk-go/aws"
    "github.com/aws/aws-sdk-go/aws/session"
    "github.com/aws/aws-sdk-go/service/dynamodb"
)

// 过滤掉所有值为空的AttributeValue字段
func filterNullAttributes(item map[string]*dynamodb.AttributeValue) map[string]*dynamodb.AttributeValue {
    filtered := make(map[string]*dynamodb.AttributeValue)
    for key, val := range item {
        // 检查AttributeValue的所有字段是否都为nil
        hasValue := val.B != nil || val.BOOL != nil || val.BS != nil ||
            val.N != nil || val.NS != nil || val.S != nil || val.SS != nil ||
            val.M != nil || val.L != nil || val.NULL != nil
        if hasValue {
            filtered[key] = val
        }
    }
    return filtered
}

func main() {
    sess, err := session.NewSession(&aws.Config{Region: aws.String("eu-central-1")})
    if err != nil {
        log.Fatalf("Failed to create session: %v", err)
    }
    dyn := dynamodb.New(sess)

    var limit int64 = 5
    out, err := dyn.Scan(&dynamodb.ScanInput{
        TableName: aws.String("Products"),
        Limit:     &limit,
    })
    if err != nil {
        log.Fatalf("Scan failed: %v", err)
    }

    if len(out.Items) > 0 {
        filteredItem := filterNullAttributes(out.Items[0])
        b, err := json.Marshal(filteredItem)
        if err != nil {
            log.Fatalf("Marshal failed: %v", err)
        }
        fmt.Println(string(b))
    }
}

不过这种方法需要手动检查所有可能的字段，代码比较冗余，适合临时快速解决问题的场景。

另外提醒一句：你的原代码里忽略了所有错误处理，实际项目中一定要记得处理这些错误，避免隐藏的bug哦！

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