将数据迁移到时间序列集合
本页介绍如何使用 聚合管道将数据迁移到时间序列集合中。或者，要了解如何使用 MongoDB Relational Migrator 将数据迁移到时间序列集合，请参阅 使用 Relational Migrator 配置时间序列集合 。
关于此任务
从 MongoDB 版本 7.0 开始，您可以使用$out聚合阶段将数据从现有集合迁移到时间序列集合中。如果您的集合存储要跨时间间隔进行比较的数据，请使用时间序列集合来提高性能和存储。有关时间序列集合优势的更多信息，请参阅时间序列集合。
开始之前
考虑一个包含时间和元数据信息的 weatherdata 集合：
db.weatherdata.insertOne( { _id: ObjectId("5553a998e4b02cf7151190b8"), st: "x+47600-047900", ts: ISODate("1984-03-05T13:00:00Z"), position: { type: "Point", coordinates: [ -47.9, 47.6 ] }, elevation: 9999, callLetters: "VCSZ", qualityControlProcess: "V020", dataSource: "4", type: "FM-13", airTemperature: { value: -3.1, quality: "1" }, dewPoint: { value: 999.9, quality : "9" }, pressure: { value: 1015.3, quality: "1" }, wind: { direction: { angle: 999, quality: "9" }, type: "9", speed: { rate: 999.9, quality: "9" } }, visibility: { distance: { value: 999999, quality : "9" }, variability: { value: "N", quality: "9" } }, skyCondition: { ceilingHeight: { value: 99999, quality: "9", determination: "9" }, cavok: "N" }, sections: [ "AG1" ], precipitationEstimatedObservation: { discrepancy: "2", estimatedWaterDepth: 999 } } )
步骤
可选。创建元数据字段。
如果您的集合不包含含有所有元数据的特定字段，请转换您的数据以定义一个。
以下管道阶段添加了 metaData 字段，并使用 $project 包含或排除文档中的其余字段。在此示例中，metaData 字段成为您创建的时间序列集合的 metaField。
注意
选择正确的字段作为时间序列 metaField 可优化存储和查询性能。有关 metaField 选择和最佳实践的更多信息，请参阅 metaFields。
{ $addFields: { metaData: { st: "$st", position: "$position", elevation: "$elevation", callLetters: "$callLetters", qualityControlProcess: "$qualityControlProcess", type: "$type" } }, }, { $project: { _id: 1, ts: 1, metaData: 1, dataSource: 1, airTemperature: 1, dewPoint: 1, pressure: 1, wind: 1, visibility: 1, skyCondition: 1, sections: 1, precipitationEstimatedObservation: 1 } }
创建您的时间序列集合并插入数据。
以下示例执行以下操作：
使用
$addFields聚合阶段将metaData字段添加到weather_data集合中。使用带有
timeseries选项的$out聚合阶段在mydatabase数据库中创建weathernew时间序列集合。将您的
weathernew集合的metaField定义为metaData字段。将您的
weathernew集合的timeField定义为ts字段。
注意
时间序列集合的 timeField 必须是日期类型。
db.weather_data.aggregate( [ { $addFields: { metaData: { st: "$st", position: "$position", elevation: "$elevation", callLetters: "$callLetters", qualityControlProcess: "$qualityControlProcess", type: "$type" } }, }, { $project: { _id: 1, ts: 1, metaData: 1, dataSource: 1, airTemperature: 1, dewPoint: 1, pressure: 1, wind: 1, visibility: 1, skyCondition: 1, sections: 1, precipitationEstimatedObservation: 1 } }, { $out: { db: "mydatabase", coll: "weathernew", timeseries: { timeField: "ts", metaField: "metaData" } } } ] )
运行此聚合管道后，您可以使用 findOne() 查看 weathernew 时间序列集合中的文档：
db.weathernew.findOne()
该操作将返回以下文档：
{ _id: ObjectId("5553a998e4b02cf7151190b8"), ts: ISODate("1984-03-05T13:00:00Z"), metaData: { st: "x+47600-047900", position: { type: "Point", coordinates: [ -47.9, 47.6 ] }, elevation: 9999, callLetters: "VCSZ", qualityControlProcess: "V020", type: "FM-13" }, dataSource: "4", airTemperature: { value: -3.1, quality: "1" }, dewPoint: { value: 999.9, quality: "9" }, pressure: { value: 1015.3, quality: "1" }, wind: { direction: { angle: 999, quality: "9" }, type: "9", speed: { rate: 999.9, quality: "9" } }, visibility: { distance: { value: 999999, quality: "9" }, variability: { value: "N", quality: "9" } }, skyCondition: { ceilingHeight: { value: 99999, quality: "9", determination: "9" }, cavok: "N" }, sections: [ "AG1" ], precipitationEstimatedObservation: { discrepancy: "2", estimatedWaterDepth: 999 } }
后续步骤
如果原始集合中有二级索引，请现在手动重新创建。
如果时间序列集合在 1970-01-01T00:00:00.000Z 之前或 2038-01-19T03:14:07.000Z 之后包含 timeField 个值，MongoDB 会记录警告并禁用某些使用内部聚集索引的查询优化。要恢复查询性能并解决日志警告问题，请在 timeField 上创建二级索引。