在Rust Lambda中将DynamoDB结果JSON转标准Web JSON

你遇到的问题核心是用Debug格式化输出了DynamoDB的AttributeValue，这不是标准JSON格式，导致前端解析失败。aws-sdk-dynamodb本身就提供了转换工具，不需要依赖rusoto或serde_dynamo，以下是两种可靠的解决方案：

方法一：直接转换为serde_json::Value（无结构体） #

适用于不需要强类型的场景，直接把DynamoDB的键值对转换成标准JSON：

use aws_config::meta::region::RegionProviderChain;
use aws_sdk_dynamodb::model::AttributeValue;
use aws_sdk_dynamodb::Client;
use lambda_runtime::{service_fn, Error as LambdaError, LambdaEvent};
use serde_json::{json, Value, Map};

// 转换DynamoDB的HashMap为标准JSON Value
fn convert_dynamo_item(item: &std::collections::HashMap<String, AttributeValue>) -> Result<Value, LambdaError> {
    let mut converted_map = Map::new();
    for (key, attr_val) in item {
        // 使用AttributeValue自带的to_json方法转换
        let json_val = attr_val.to_json()?;
        converted_map.insert(key.clone(), json_val);
    }
    Ok(Value::Object(converted_map))
}

async fn function_handler(event: LambdaEvent<Value>) -> Result<Value, LambdaError> {
    // 初始化DynamoDB客户端（省略原有逻辑）
    let region_provider = RegionProviderChain::default_provider().or_else("us-east-1");
    let config = aws_config::from_env().region(region_provider).load().await;
    let client = Client::new(&config);

    let key_value = "your_key_here"; // 从事件中获取实际key
    let item = client
        .get_item()
        .table_name("example_table")
        .key("example_key", AttributeValue::S(key_value.to_string()))
        .send()
        .await?;

    match item.item() {
        Some(mapped_value) => {
            let converted_item = convert_dynamo_item(mapped_value)?;
            // 序列化标准JSON作为响应体
            Ok(json!({
                "statusCode": 200,
                "headers": {
                    "Content-Type": "application/json"
                },
                "body": serde_json::to_string(&converted_item)?
            }))
        }
        None => {
            Ok(json!({
                "statusCode": 404,
                "body": "Item not found"
            }))
        }
    }
}

#[tokio::main]
async fn main() -> Result<(), LambdaError> {
    lambda_runtime::run(service_fn(function_handler)).await
}

方法二：用强类型结构体转换（推荐） #

如果你的数据结构固定，定义对应结构体可以获得类型安全，避免运行时错误：

use aws_config::meta::region::RegionProviderChain;
use aws_sdk_dynamodb::model::AttributeValue;
use aws_sdk_dynamodb::Client;
use lambda_runtime::{service_fn, Error as LambdaError, LambdaEvent};
use serde::{Deserialize, Serialize};
use serde_json::{json, Value};
// 导入DynamoDB到结构体的转换方法
use aws_sdk_dynamodb::deserialize::aws_sdk_dynamodb::from_attr_value;

// 定义与DynamoDB表结构对应的结构体
#[derive(Debug, Deserialize, Serialize)]
struct ExampleItem {
    load: i32,
    name: String,
    item_type: String,
}

async fn function_handler(event: LambdaEvent<Value>) -> Result<Value, LambdaError> {
    // 初始化客户端（省略原有逻辑）
    let region_provider = RegionProviderChain::default_provider().or_else("us-east-1");
    let config = aws_config::from_env().region(region_provider).load().await;
    let client = Client::new(&config);

    let key_value = "your_key_here";
    let item = client
        .get_item()
        .table_name("example_table")
        .key("example_key", AttributeValue::S(key_value.to_string()))
        .send()
        .await?;

    match item.item() {
        Some(mapped_value) => {
            // 将DynamoDB的AttributeValue Map转换为结构体
            let example_item: ExampleItem = from_attr_value(AttributeValue::M(mapped_value.clone()))?;
            Ok(json!({
                "statusCode": 200,
                "headers": {
                    "Content-Type": "application/json"
                },
                "body": serde_json::to_string(&example_item)?
            }))
        }
        None => {
            Ok(json!({
                "statusCode": 404,
                "body": "Item not found"
            }))
        }
    }
}

#[tokio::main]
async fn main() -> Result<(), LambdaError> {
    lambda_runtime::run(service_fn(function_handler)).await
}

关键说明 #

1. 为什么原有代码报错：format!("{:?}", mapped_value)输出的是Rust的Debug格式字符串（比如N("2")、S("Superlaser")），这根本不是标准JSON，所以前端会抛出SyntaxError。
2. 自带转换工具的优势：AttributeValue::to_json()和from_attr_value()是AWS SDK for Rust原生提供的方法，与SDK版本兼容性更好，不需要额外依赖。
3. 错误处理优化：替换了原代码中的unwrap()，改用match处理Option，避免Lambda运行时panic。

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