名词解释

bucket：带有相同的元数据且在一段有限制的间 隔区间内的测量值组。

bucket collection ：用于存储时序型集合的底层的分组桶的系统集合。复制、分片和索引都是在桶级别上完成的。

measurement：带有特定时间序列的K-V集合。

meta-data：时序序列里很少随时间变化的K-V对，同时可以用于识别整个时序序列。

time-series：一段间隔内的一系列测量值。

time-series collection：一种表示可写的非物化的视图的集合类型，它允许存储和查询多个时间序列，每个序列可以有不同的元数据。

MongoDB 在5.0中支持了新的timeseries collection类型的选项，该类型用于存储时序型数据。timeseriescollection提供了一组用于插入和查询测量值的简单接口，同时底层实际的数据是存储在以bucket形式的集合中。

在创建timeseriescollection时，timeField字段是最小必备的配置项。metaField是另一个可选的、可被指定的元数据字段，它是用于在bucket中对测量值分组的依据。MongoDB通过提供expireAfterSeconds字段选项，也支持了对测量值的过期机制。

在mydb数据库中有个以mytscoll 命名的timeseriescollection，该集合在MongoDB内部的catelog(用于存储集合或视图的信息)里是由一个视图和一个系统集合组成的。

该视图就是通过aggregation里的$_internalUnpackBucket来实现展开bucket里数据的。

该视图是可写的(仅支持插入)。同时每个被插入的文档必须包含时间字段。

在查询视图时，它会隐式地展开底层在bucket collection中存储的数据，然后返回原始的非bucket形式的文档数据。

每一个在bucket collection里的文档，都表示了一组区间间隔的时序型数据。

如果在创建timeseriescollection时，定义了metaField元数据字段，那么所有在bucket里的测量值都会有这个通用的元数据字段。

除了时间范围，bucket还限制了每个文档数据的总条数以及测量值的大小。

Bucket Collection Schema

_id Object ID with  component equal to control. fieldcontrol  Some statistics  the measurements such minmax  of>>version  Version of bucket schema. Currently fixed at  since this  the first iteration of series collections.min  field  of first measurement  this bucket rounded down based  granularityfield0 minimum value of  across all measurementsfield1 maximum value of  across all measurements...max  field  of last measurement  this bucketfield0 maximum value of  across all measurementsfield1 maximum value of  across all measurements...closed   Optional signals the>not receive any additional measurements.meta metadata field if specified at creation value common to all measurements  this bucketdata  field   of first measurement  of second measurement...  of nth measurementfield0  value of   first measurement value of   first measurement...field1  value of   first measurement value of   first measurement......

索引

为了保证timeseries collection的查询可以受益于索引扫描而不是全表扫描，timeseriescollection允许索引可以被创建在时间上，元数据上以及元数据的子属性上。从MongoDB5.2开始，在timeseriescollection也允许索引被创建在测量值上。用户使用createIndex命令提供的索引规范被转换为底层buckets collection的模式。

当索引被创建后，可以通过listIndexes命令或$indexStats聚合计划来检查。listIndexes和$indexStats是作用于timeseries collections的，执行时，它们会在内部将底层的bucketcollection的索引转化成timeseries格式的索引，并返回。比如，当我们在元数据字段中定义有mm的timeseriescollection上执行listIndexes命令时，底层的bucket collection的{meta:1}索引，将会以{mm:1}格式返回。

dropIndex 和collMod (hidden: , expireAfterSeconds: ) 也同样支持在timeseriescollection上。

时间字段上支持的索引类型：

元数据字段和元数据子字段支持的索引类型：

仅在v5.2及以上版本，测量值字段支持的索引类型：

`timeseries collections 上不支持的索引类型，包括 唯一索引以及文本索引。

桶目录

为了保证高效地桶(分组)操作，我们在BucketCatalog里维护了一组开启的桶，你可以在bucket_catalog.h找到。在更高的级别，我们尝试着把并发写程序的写操作分组合并为可以一起提交地批处理，以减少对底层文档的写次数。写程序会插入它的输入批处理里的每一个文档到BucketCatalog，然后BucketCatalog会返回一个BucketCatalog::WriteBatch的处理器。一旦完成上面那些插入操作后，写程序就会检查每个写批处理。如果没有其他的写程序已经对批处理声明提交的权利，那么它会声明权利，并会提交它的批处理。否则，写程序将会稍后再提交处理。当它检查完所有的批处理，写程序将会等待其他的写程序提交每个剩下的批处理。

在内部，BucketCatalog维护一组对每个bucket文档的更新操作。当批处理被提交时，它会将这些插入转换到成buckets的列格式，并确保任何control字段的更新(例如control.min 和control.max)。

当bucket文档在没有通过BucketCatalog的情况下被更新时，写程序就需要为有问题的文档或命名空间去调用BucketCatalog::clear，这样它就可以更新它的内部状态，避免写入任何可能破坏bucket 格式的数据。这通常由OP观察者处理，但可能需要通过其他地方去调用。

bucket既可以通过手动设置选项control.closed 标识来关闭，也可以在许多场景下通过 BucketCatalog自动关闭。如果BucketCatalog使用了超出给定的阈值(可通过服务器参数timeseriesIdleBucketExpiryMemoryUsageThreshold控制)的更多内存，此时它将会开始去关闭空闲的bucket。如果bucket是开启的且它没有任何未处于等待中未提交的测量值时，那么它就会被视为空闲的bucket。在下面这些场下BucketCatalog 也会关闭bucket:如果它拥有超过最大阈值(timeseriesBucketMaxCount)的测量值数据的数量;如果它拥有过大的数据量大小(timeseriesBucketMaxSize);又或者一个新的测量值数据是否是会导致bucket在其最旧的时间戳和最新的时间戳之间跨度比允许的间隔更长的时间(当前硬编码为一小时)。如果传入的测量值在原理上与已经到达给定bucket的度量不兼容，该bucket将被关闭，同时可以使用numBucketsClosedDueToSchemaChange度量进行跟踪。

在第一次提交给定bucket的写批处理时，就会生成新的完整的文档。后续的批处理提交中，我们只执行更新操作，不再生成新的完整的文档(因此称为‘经典’更新)，是直接创建DocDiff(“delta”或者v2的更新)。

粒度

timeseries collection的granularity选项在集合创建的时候，可以被设置成seconds，minutes或者hours。后期可通过colMod操作来修改这个选项从seconds到minutes或者从minutes到hours，除此之外的转化修改目前都是不支持的。该参数想要表示在已给定的时序型测量数据之间的粗略的时间间隔，同时也用于调节其他内部参数对分组的影响。

单个bucket被允许的最大时间跨度，是由granularity选项控制，对于seconds，最大的时间跨度被设置成1小时，对于minutes就是24小时，对于hours就是30天。

当通过BucketCatalog开启新的bucket时，_id里的时间戳就是等同于control.min.的值，该值是从第一个插入bucket的测量数据中根据granularity选项来向下近似舍入而得到的。对于seconds，它将向下舍入到最接近的分钟，对于minutes，将向下舍入到最接近的小时，对于hours，它将向下舍入到最接近的日期。在闰秒和日历中的其他不规则情况下，这种舍入可能并不完美，并且通常通过对自纪元以来的秒数进行基本模运算来完成，假设每分钟60 秒，每小时 60 分钟，以及每天 24 小时。

更新和删除

timeseries collection 支持符合以下限制的删除语句：

同时更新满足上面同样的条件，另外遵循：

这些更新与删除的执行都会被转换成相对应的底层的bucket collection的更新或删除操作。特别是，对于查询和更新文档，我们会使用真正的字段meta替换集合的metaField。(参见 Bucket 集合规范)

例如，对于一个使用 metaField:"tag"创建的timeseries集合db.ts，考虑一个对这个集合的更新操作，其查询语句是{"tag.tag.a": "a"} ，同时更新文档语句是{$set: {"tag.tag.a": "A"}, $rename: {"tag.tag.b": "tag.tag.c"}}。这个更新操作在db.system.buckets.ts上会被转换成，查询语句是{"meta.tag.a": "a"}，更新语句是 {$set: {"meta.tag.a":"A"}, $rename: {"meta.tag.b":"meta.tag.c"}}。然后这个转换后的更新语句就可以像普通的更新操作一样执行。上面这些转换流程也适用于删除操作。

参考文献

MongoDB Blog: Time Series> 关于作者：黄璜

目前就职于上海DerbySoft，主要从事基础架构中业务流程设计及研发的工作，平时工作中MongoDB使用的较多。

在提升自己外文的能力的同时，也希望为社区做出微小的贡献。