AWS Lambda中JSON对象损坏：MongoDB存储异常排查

看起来你遇到的是非标准JSON格式的问题——那种{first_name=Arun, ...}的写法根本不是合法JSON，它更像是编程语言里字典/哈希表的默认字符串输出（比如Python的str(dict)或者Java的HashMap.toString()），这就导致MongoDB无法正确解析。

我来给你拆解问题原因和解决办法：

问题根源 #

你发送的原始JSON是标准键值对格式，但在Lambda的处理流程中，某个环节把JSON对象转换成了语言原生集合的字符串表示，而不是用JSON序列化工具生成标准JSON。比如：

• Python里如果用str(user_dict)代替json.dumps(user_dict)，就会得到这种等号格式
• Java里如果直接调用HashMap.toString()而不是用Jackson/Gson序列化，也会出现类似情况

针对性解决办法 #

如果你用的是Python Lambda #

确保全程用json模块来处理JSON的序列化/反序列化：

1. 解析输入请求体时，用json.loads()把字符串转成字典
2. 准备插入MongoDB时，直接传入字典（pymongo会自动把字典转换成MongoDB支持的BSON格式）；如果需要转成JSON字符串，用json.dumps()而不是str()

示例代码片段：

import json
import pymongo

def lambda_handler(event, context):
    # 第一步：正确解析API Gateway传来的请求体
    try:
        user_data = json.loads(event.get('body', '{}'))
    except json.JSONDecodeError:
        return {"statusCode": 400, "body": json.dumps("Invalid JSON input")}
    
    # 第二步：连接MongoDB并插入数据（注意替换你的URI、库名和集合名）
    client = pymongo.MongoClient("mongodb+srv://<user>:<password>@cluster0.mongodb.net/")
    db = client["your_database"]
    collection = db["users"]
    
    # 直接插入字典，无需手动转成字符串
    insert_result = collection.insert_one(user_data)
    
    return {
        "statusCode": 200,
        "body": json.dumps(f"User added successfully with ID: {str(insert_result.inserted_id)}")
    }

如果你用的是Java Lambda #

用Jackson或Gson这类成熟的JSON序列化库，不要直接调用对象的toString()方法：

1. 用ObjectMapper把Java对象序列化成标准JSON字符串
2. 插入MongoDB时，要么传递JSON字符串，要么直接传递Java对象（MongoDB的Java驱动会自动处理）

示例代码片段（Jackson）：

import com.fasterxml.jackson.databind.ObjectMapper;
import com.mongodb.client.MongoClients;
import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.MongoCollection;
import org.bson.Document;

public class LambdaHandler implements RequestHandler<APIGatewayProxyRequestEvent, APIGatewayProxyResponseEvent> {
    private final ObjectMapper objectMapper = new ObjectMapper();
    
    @Override
    public APIGatewayProxyResponseEvent handleRequest(APIGatewayProxyRequestEvent event, Context context) {
        APIGatewayProxyResponseEvent response = new APIGatewayProxyResponseEvent();
        
        try {
            // 解析请求体为User对象（假设你有对应的POJO类）
            User user = objectMapper.readValue(event.getBody(), User.class);
            
            // 连接MongoDB并插入
            try (MongoClient mongoClient = MongoClients.create("your_mongo_uri")) {
                MongoDatabase database = mongoClient.getDatabase("your_database");
                MongoCollection<Document> collection = database.getCollection("users");
                
                // 把User对象转成Document插入
                collection.insertOne(Document.parse(objectMapper.writeValueAsString(user)));
            }
            
            response.setStatusCode(200);
            response.setBody("User added successfully");
        } catch (Exception e) {
            response.setStatusCode(500);
            response.setBody("Error processing request: " + e.getMessage());
        }
        
        return response;
    }
    
    // 对应的User POJO类
    static class User {
        private String first_name;
        private String last_name;
        // 其他字段和getter/setter
    }
}

额外检查点 #

1. 确认Lambda的触发源（比如API Gateway）是否正确传递了原始JSON请求体，没有做额外的格式转换
2. 查看Lambda日志，定位是在输入解析环节还是输出插入环节出现了格式转换，针对性排查代码

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