要解决此问题,您需要对数据结构进行一些小的修改。听上去,要让您的文档超过 16mb 的限制,您必须将传感器数据嵌入到单个文档的数组中。
我不建议在这里使用 GridFS,我不认为它是最好的解决方案,这就是原因。
您可以使用一种称为分桶的技术,它实质上会将您的传感器读数分成单独的文档,从而为您解决这个问题。
它的工作方式是这样的:
假设我有一个文档,其中包含特定传感器的一些嵌入式读数,如下所示:
{
_id : ObjectId("xxx"),
sensor : "SensorName1",
readings : [
{ date : ISODate("..."), reading : "xxx" },
{ date : ISODate("..."), reading : "xxx" },
{ date : ISODate("..."), reading : "xxx" }
]
}
上面的结构已经有一个很大的缺陷,读数数组可能会呈指数级增长,并超过 16mb 文档的限制。
所以我们可以做的是稍微改变结构,使其看起来像这样,以包含一个计数属性:
{
_id : ObjectId("xxx"),
sensor : "SensorName1",
readings : [
{ date : ISODate("..."), reading : "xxx" },
{ date : ISODate("..."), reading : "xxx" },
{ date : ISODate("..."), reading : "xxx" }
],
count : 3
}
这背后的想法是,当您将读数 $push 到嵌入式数组中时,每次执行的推送都会增加 ($inc) 计数变量。当你执行这个更新(推送)操作时,你会在这个“count”属性上包含一个过滤器,它可能看起来像这样:
{ count : { $lt : 500} }
然后,设置您的更新选项,以便您可以将“upsert”设置为“true”:
db.sensorReadings.update(
{ name: "SensorName1", count { $lt : 500} },
{
//Your update. $push your reading and $inc your count
$push: { readings: [ReadingDocumentToPush] },
$inc: { count: 1 }
},
{ upsert: true }
)
有关 MongoDb 更新和 Upsert 选项的更多信息,请参见此处:
MongoDB update documentation
当过滤条件不满足时会发生什么(即当这个传感器没有现有文档,或者计数大于或等于 500 - 因为每次推送项目时都会增加它) ,将创建一个新文档,并且读数现在将嵌入到这个新文档中。因此,如果您正确执行此操作,您将永远不会达到 16mb 的限制。
现在,当查询数据库以获取特定传感器的读数时,您可能会返回该传感器的多个文档(而不是仅包含所有读数的一个文档),例如,如果您有 10,000 个读数,您将获得返回 20 个文档,每个文档有 500 个读数。
然后,您可以使用聚合管道和 $unwind 过滤您的读数,就好像它们是它们自己的单个文档一样。
有关 unwind 的更多信息,请参见此处,它非常有用
MongoDB Unwind
我希望这会有所帮助。