使用C# MongoDB驱动，能否通过LINQ创建按时间间隔分组的聚合？

当然可以！用C# MongoDB驱动结合LINQ完全能实现按时间间隔分组的聚合操作，下面我给你两种实现方式，完美对应你给出的MongoDB聚合管道示例：

方式一：纯LINQ写法（类型安全） #

这种写法利用C#驱动的LINQ映射能力，自动将LINQ表达式转换成对应的MongoDB聚合操作符，代码可读性强且类型安全。

首先假设你的实体类定义如下：

public class YourEntity
{
    public ObjectId Id { get; set; }
    public DateTime Time { get; set; }
    // 其他业务字段...
}

然后构建聚合查询：

// 获取集合引用
var collection = mongoDatabase.GetCollection<YourEntity>("your_collection_name");

// 构建聚合管道：先投影出按10分钟间隔的时间分组字段，再分组统计数量
var aggregateQuery = collection.Aggregate()
    .Project(entity => new 
    {
        DateGroup = new 
        {
            Year = entity.Time.Year,
            Month = entity.Time.Month,
            Day = entity.Time.Day,
            Hour = entity.Time.Hour,
            Minute = entity.Time.Minute - (entity.Time.Minute % 10) // 按10分钟取整
        }
    })
    .Group(projected => projected.DateGroup, group => new 
    {
        _id = group.Key,
        Count = group.Count()
    });

// 执行查询并获取结果
var result = await aggregateQuery.ToListAsync();

这里LINQ会自动把Year映射为$year操作符，Minute % 10映射为$mod，减法运算映射为$subtract，和你给出的原生管道逻辑完全一致。

方式二：原生BsonDocument写法（灵活适配复杂场景） #

如果遇到LINQ难以直接映射的复杂MongoDB操作符，你也可以直接用BsonDocument构建和原生MongoDB完全一致的聚合管道，这种方式灵活性更高。

先定义结果接收类：

public class TimeGroupResult
{
    public DateGroup _id { get; set; }
    public int Count { get; set; }
}

public class DateGroup
{
    public int Year { get; set; }
    public int Month { get; set; }
    public int Day { get; set; }
    public int Hour { get; set; }
    public int Minute { get; set; }
}

然后构建并执行管道：

var pipeline = new BsonDocument[]
{
    new BsonDocument("$project", new BsonDocument
    {
        { "date", new BsonDocument
            {
                { "year", new BsonDocument("$year", "$time") },
                { "month", new BsonDocument("$month", "$time") },
                { "day", new BsonDocument("$dayOfMonth", "$time") },
                { "hour", new BsonDocument("$hour", "$time") },
                { "minute", new BsonDocument("$subtract", new BsonArray
                    {
                        new BsonDocument("$minute", "$time"),
                        new BsonDocument("$mod", new BsonArray { new BsonDocument("$minute", "$time"), 10 })
                    })
                }
            }
        }
    }),
    new BsonDocument("$group", new BsonDocument
    {
        { "_id", "$date" },
        { "count", new BsonDocument("$sum", 1) }
    })
};

var aggregate = collection.Aggregate<TimeGroupResult>(pipeline);
var result = await aggregate.ToListAsync();

两种方式对比 #

• LINQ写法：优势是类型安全，编译期就能发现错误，代码更符合C#开发习惯，适合常规聚合场景。
• BsonDocument写法：完全复刻MongoDB原生语法，适合处理复杂的、LINQ难以覆盖的聚合逻辑，自由度更高。

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