分片时间序列集合
5.1 版本中的新功能。
使用本教程对新的或现有的时间序列集合进行分片。
重要
在完成本教程之前，请查看时间序列集合的分片限制 。
先决条件
要对时间序列集合进行分片，必须部署分片集群来托管包含您的时间序列集合的数据库。
步骤
分片新时间序列集合
2
确认您的数据库已启用分片。
运行 sh.status() 以确认您的数据库已启用分片：
sh.status()
该命令返回分片信息：
--- Sharding Status --- sharding version: { "_id" : 1, "minCompatibleVersion" : 5, "currentVersion" : 6, ...
3
创建集合。
使用带有时间序列选项的 shardCollection() 方法。
例如：
sh.shardCollection( "test.weather", { "metadata.sensorId": 1 }, { timeseries: { timeField: "timestamp", metaField: "metadata", granularity: "hours" } } )
在此示例中，sh.shardCollection()：
在
test数据库上分割名为weather的新时间序列集合。将
metadata.sensorId字段指定为分片键。将
granularity指定为小时。
以下文档包含集合的相应元数据：
db.weather.insertOne( { "metadata": { "sensorId": 5578, "type": "temperature" }, "timestamp": ISODate("2021-05-18T00:00:00.000Z"), "temp": 12 } )
对现有时间序列集合进行分片
1
2
确认您的数据库已启用分片。
运行 sh.status() 以确认您的数据库已启用分片：
sh.status()
该命令返回分片信息：
--- Sharding Status --- sharding version: { "_id" : 1, "minCompatibleVersion" : 5, "currentVersion" : 6, ...
3
在集合上创建哈希索引。
创建支持分片键的索引，以便在集合上启用分片。
考虑具有以下属性的时间序列集合：
db.createCollection( "deliverySensor", { timeseries: { timeField: "timestamp", metaField: "metadata", granularity: "minutes" } } )
集合中的示例文档如下所示：
db.deliverySensor.insertOne( { "metadata": { "location": "USA", "vehicle": "truck" }, "timestamp": ISODate("2021-08-21T00:00:10.000Z"), "speed": 50 } )
运行以下命令，以便在 metadata.location 字段创建哈希索引：
db.deliverySensor.createIndex( { "metadata.location" : "hashed" } )
4
对您的集合分片
使用 shardCollection() 方法对集合进行分片。
若要对上一步中所述的 deliverySensor 集合进行分片，请运行以下命令：
sh.shardCollection( "test.deliverySensor", { "metadata.location": "hashed" } )
在此示例中，sh.shardCollection()：
在
test数据库上分片名为deliverySensor的现有时间序列集合。将
metadata.location字段指定为分片键。location是该集合的metaField的子字段。
如果指定到 sh.shardCollection() 的集合是时间序列集合，那么您无需指定时间序列选项。