如何用Rust将无预定义结构的JSON对象存入DynamoDB？

结论：用serde_dynamo是最优解 #

由于你无法预先知晓JSON结构，serde_dynamo是专门处理serde序列化数据与DynamoDB AttributeValue之间转换的库，完美适配这种动态场景。

具体操作步骤 #

1. 添加依赖 #

在Cargo.toml中引入所需依赖：

[dependencies]
serde = { version = "1.0", features = ["derive"] }
serde_json = "1.0"
serde_dynamo = "0.13"
aws-sdk-dynamodb = "1.0"

其中aws-sdk-dynamodb是AWS官方SDK，与serde_dynamo完全兼容。

2. 将serde_json::Value转成AttributeValue #

利用serde_dynamo的to_attribute_value方法，直接转换动态JSON值：

use serde_json::Value;
use serde_dynamo::to_attribute_value;
use aws_sdk_dynamodb::types::AttributeValue;

fn main() -> Result<(), Box<dyn std::error::Error>> {
    // 模拟读取到的动态JSON字符串
    let json_str = r#"{"name": "Alice", "age": 30, "tags": ["rust", "dynamodb"]}"#;
    let json_value: Value = serde_json::from_str(json_str)?;

    // 转换为DynamoDB所需的AttributeValue
    let attr_value: AttributeValue = to_attribute_value(json_value)?;

    // 构建存入请求（示例）
    let put_item_input = aws_sdk_dynamodb::input::PutItemInput::builder()
        .table_name("your-table-name")
        .item("data", attr_value) // 若需将JSON字段作为顶级属性，见下一步
        .build()?;

    // 后续调用AWS SDK的put_item方法完成存入（需提前初始化客户端）
    // client.put_item(put_item_input).await?;

    Ok(())
}

3. 将JSON字段直接作为DynamoDB顶级属性 #

如果你的JSON是扁平结构，想把每个键值对直接作为表的属性，用to_items方法转成HashMap<String, AttributeValue>：

use serde_json::Value;
use serde_dynamo::to_items;
use std::collections::HashMap;
use aws_sdk_dynamodb::types::AttributeValue;

fn main() -> Result<(), Box<dyn std::error::Error>> {
    let json_str = r#"{"name": "Alice", "age": 30, "tags": ["rust", "dynamodb"]}"#;
    let json_value: Value = serde_json::from_str(json_str)?;

    // 转换为DynamoDB表项格式
    let item: HashMap<String, AttributeValue> = to_items(json_value)?;

    let put_item_input = aws_sdk_dynamodb::input::PutItemInput::builder()
        .table_name("your-table-name")
        .set_item(Some(item))
        .build()?;

    // 后续调用SDK方法完成存入
    Ok(())
}

4. 反向转换（从DynamoDB读回JSON） #

如果需要从DynamoDB读取数据转回serde_json::Value，用对应的反向方法即可：

// 从AttributeValue转回Value
let json_value: Value = serde_dynamo::from_attribute_value(attr_value)?;

// 从表项HashMap转回Value
let json_value: Value = serde_dynamo::from_items(item)?;

注意事项 #

• 确保serde_dynamo与aws-sdk-dynamodb版本兼容，建议使用最新稳定版。
• 嵌套JSON会被自动递归转换，无需手动处理复杂结构。
• DynamoDB不支持的类型（如浮点数）会被自动兼容转换为Number类型，无需额外操作。

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