MongoDB时间序列查询未用索引耗时过长问题排查

场景描述 #

我有一个名为Events的百万级MongoDB时间序列集合，文档结构如下：

{
  "_id": {"$oid": "123456"},
  "class": "...",
  "event_data": {...},
  "ts": {"$date": "2025-01-01T01:00:00.000Z"}
}

该集合的ts字段已创建升序（ts_1）和降序（ts_-1）索引。我用Java编写的查询拉取两个时间戳之间的文档时耗时约20分钟，触发全集合扫描；但在MongoDB控制台用Date对象编写的相同逻辑查询仅需数秒，能正常触发索引扫描。

Java查询代码（未触发索引） #

ZonedDateTime lowerBound = ...;
ZonedDateTime upperBound = ...;

var query = Query.query(new Criteria().andOperator(
  Criteria.where("ts").gte(lowerBound.toInstant().toEpochMilli()),
  Criteria.where("ts").lt(upperBound.toInstant().toEpochMilli())
));

var result = mongoTemplate.find(query, Events.class);

调试可见查询格式为：

Query: { "$and" : [{ "ts": { "$gte" : 1733852133000}}, { "ts" : { "$lt": 1733853933000}} ] }

控制台有效查询（触发索引） #

db.events.find({
  "$and": [
    { "ts": { "$gte": new Date("2025-01-01T01:00:00Z")}},
    { "ts": { "$lt": new Date("2025-01-02T01:00:00Z")}},
  ]
})

已尝试但无效的方案 #

• 使用Instant或Date替代Long作为查询值，仍触发全集合扫描；
• 添加hint("ts_1")强制使用索引，控制台报错索引不存在（实际索引存在），Java中仍为全表扫描。

补充信息 #

通过db.events.getIndexes()确认ts_1和ts_-1索引存在。有效查询的explain显示会对control.min.ts、control.max.ts和_id进行过滤，走IXSCAN；无效查询则先执行COLLSCAN，再进行桶解析和事件过滤。

核心差异分析 #

1. 数据类型不匹配
   无效查询用Long型毫秒数作为查询条件，而集合中ts字段是MongoDB的Date类型，索引是基于Date类型创建的。MongoDB无法将Long值与Date类型的索引匹配，因此只能执行全集合扫描。

2. 时间序列集合的特殊优化失效
   MongoDB时间序列集合采用桶化存储，有效查询用Date类型条件时，MongoDB会利用桶的control.min.ts和control.max.ts字段快速过滤掉不包含目标时间范围的桶，直接触发IXSCAN；而Long类型的查询无法触发这个桶级优化，只能扫描所有桶后再逐个解析内部事件，导致性能极差。

解决方法 #

1. 确保查询条件使用Date/Instant类型，而非毫秒数 #

Spring Data MongoDB会自动将Instant或Date类型转换为MongoDB的Date类型，与集合字段类型匹配，从而触发索引优化。修改后的Java代码：

ZonedDateTime lowerBound = ...;
ZonedDateTime upperBound = ...;

// 直接使用Instant作为查询值，无需转成毫秒数
var query = Query.query(Criteria.where("ts")
    .gte(lowerBound.toInstant())
    .lt(upperBound.toInstant()));

var result = mongoTemplate.find(query, Events.class);

2. 检查实体类的字段映射 #

确保Events类中的ts字段被正确映射为Date或Instant类型，避免类型不匹配：

import org.springframework.data.mongodb.core.mapping.Field;
import java.time.Instant;

public class Events {
    private String id;
    @Field("class") // 避免Java关键字冲突
    private String clazz;
    private Object eventData;
    @Field("ts")
    private Instant ts; // 或使用java.util.Date ts;

    // getter和setter方法
}

3. 正确使用索引提示（可选） #

如果上述调整后仍有问题，可强制指定索引，但需确保索引名称正确（注意时间序列集合的索引是在主集合上，而非内部桶集合）：

query.withHint("ts_1"); // 指定升序索引

内容的提问来源于stack exchange，提问作者ben8622