本文介绍使用 MongoDB 聚合管道（$objectToArray、$filter、$unwind、$project）将原始文档中动态键名的嵌入对象（如 "750544": { "createdAt": ... }）批量转换为标准化的扁平化文档，每个嵌入对象生成一条新记录，并保留原始 id 字段、提取键名为 messageId、值中的字段（如 createdAt）作为顶层字段。
本文介绍使用 mongodb 聚合管道（`$objecttoarray`、`$filter`、`$unwind`、`$project`）将原始文档中动态键名的嵌入对象（如 `"750544": { "createdat": ... }`）批量转换为标准化的扁平化文档，每个嵌入对象生成一条新记录，并保留原始 `id` 字段、提取键名为 `messageid`、值中的字段（如 `createdat`）作为顶层字段。
在实际业务场景中（例如消息系统、日志归档或事件溯源），MongoDB 文档常以“键-嵌入对象”形式存储多条关联记录（如不同 messageId 对应的元数据），但这种结构不利于索引、查询与跨文档聚合。理想的数据模型应是每条嵌入内容作为独立文档，统一字段结构，便于分页、排序、按 messageId 精确查询等操作。
以下聚合管道可高效完成该转换任务：
db.collection.aggregate([
{
$set: {
data: {
$filter: {
input: { $objectToArray: "$$ROOT" },
cond: {
$not: { $in: ["$$this.k", ["_id", "id"]] }
}
}
}
}
},
{ $unwind: "$data" },
{
$project: {
_id: 0, // 显式排除原 _id，由 MongoDB 自动生成新 ObjectId
id: 1,
messageId: "$data.k",
createdAt: "$data.v.createdAt"
}
}
])
✅ 关键步骤说明：
- $objectToArray: "$$ROOT"：将整个文档转为键值对数组（如 [{"k":"920543","v":{"createdAt":1667210991769}}, ...]）；
- $filter：剔除 _id 和 id 字段，只保留动态消息键（如 "750544"）；
- $unwind：将过滤后的 data 数组展开为多条流式文档；
- $project：重构成目标结构 —— id 保留、messageId 取键名 k、createdAt 取嵌入对象的 v.createdAt；_id: 0 确保插入时由 MongoDB 自动分配新 ObjectId。
⚠️ 注意事项：
- 此聚合输出的是只读结果集。若需持久化为新集合，请在管道末尾追加 $merge 阶段（如 { $merge: { into: "messages", on: "_id", whenMatched: "replace", whenNotMatched: "insert" } }）；
- 若嵌入对象结构不统一（部分缺失 createdAt），建议在 $project 中使用 $ifNull 或 $cond 提供默认值，避免字段丢失；
- 动态键名数量较多时，$unwind 可能显著增加内存消耗，生产环境建议配合 allowDiskUse: true 执行；
- 原始文档中若存在其他非消息字段（如 status、updatedAt），需在 $filter 的 "$in" 列表中补充排除，防止误入结果。
通过该方案，您可将原本难以查询的嵌套结构，转化为符合 MongoDB 最佳实践的规范化集合，大幅提升数据可维护性与分析灵活性。
