在Mongodb中按日期汇总

我正在编写一个function,我需要按日期分组。 这是我目前的做法:

//Assuming this is my sample document in the collection { "_id" : ObjectId("56053d816518fd1b48e062f7"), "memberid" : "7992bc31-c3c5-49e5-bc40-0a5ba41af0bd", "sourceid" : NumberInt(3888), "ispremium" : false, "createddate" : { "DateTime" : ISODate("2015-09-25T12:26:41.157+0000"), "Ticks" : NumberLong(635787808011571008) }, "details": { //a large sub-document } } 

给定会员ID,开始日期和结束日期; 我需要搜索与这些filter匹配的集合,并按日期对结果进行分组。 换句话说,我需要实现的结果是一个列表(例如,2015年12月10日 – 计数是5,13 / 10/2015 – 计数是2)。 StartDate和EndDate是DateTime的类型。

C#是我使用的编程语言,目前我写的方式是:

  var builder = Builders.Filter; var filter = builder.Eq(d => d.MemberId, memberId) & builder.Gte(d => d.CreatedDate, startDate) & builder.Lt(d => d.CreatedDate, endDate.AddDays(1)); var group = collection.Aggregate() .Match(filter) .Group(new BsonDocument { { "_id", "$createddate" }, { "count", new BsonDocument("$sum", 1) } }) .ToListAsync().Result; 

然后我将结果反序列化为自定义类…

 List grouped = group.Select(g => BsonSerializer.Deserialize(g)).OrderBy(g => g.Date).ToList(); 

这个代码失败的地方很明显,就是分组部分。 在我的情况下,理想的是按日期而不是DateTime进行分组。 我在这里阅读了组文档和一些类似的线程,但不幸的是,我无法让它工作。 我的一个尝试是按照文档中的建议进行。 原始的mongo查询将是:

 db.mycollection.aggregate( [ { $group : { _id : { month: { $month: "$createddate" }, day: { $dayOfMonth: "$createddate" }, year: { $year: "$createddate" } }, count: { $sum: 1 } } } 

])

为了让这一点有用,我遗漏了$ match。 我得到的例外是“无法从BSON类型对象转换为日期”。

总之,我当前的代码可以工作,但基于DateTime(而不仅仅是Date)的“group”,它最终会在一个特定的日期单独计算。 我很好奇它是否可以实现。 未知是我的mongo部分,因为我还没有想出如何做到这一点。(即使在原始的mongo查询中)。

只是要澄清一些其他信息,我在C#中为datetime对象提供了以下数据注释(不确定这是否会影响):

 [BsonDateTimeOptions(Representation = BsonType.Document)] public DateTime CreatedDate {get; set; } 

我想到的一个解决方案是,是否可以动态投影“createddate”字段并将其格式化为“Ymd”,并根据投影字段进行分组。

我试图添加尽可能多的细节和我迄今为止所做的工作,只是为了让它更清晰。 我希望这不会造成任何混淆。 我很感激任何有助于我产生我想要的结果的帮助/建议。 谢谢!

根据@chridam的评论,我能够修复它。 再次感谢!

我正在编写下面的解决方案,以防万一,如果有人碰到我遇到的同样的问题。

我改变了我的查询,以便我成为:

  var group = collection.Aggregate() .Match(filter) .Group(new BsonDocument { { "_id", new BsonDocument { { "month", new BsonDocument("$month", "$createddate.DateTime") }, { "day", new BsonDocument("$dayOfMonth", "$createddate.DateTime") }, { "year", new BsonDocument("$year", "$createddate.DateTime") } } }, { "count", new BsonDocument("$sum", 1) } }) .ToListAsync().Result; 

这给了我一个序列化的对象。 然后我将它反序列化为我的自定义类:

 var grouped = group.Select(g => BsonSerializer.Deserialize(g)); 

这是自定义类定义,有点夸张:

 public class Id { public int month { get; set; } public int day { get; set; } public int year { get; set; } } public class RootObject { public Id _id { get; set; } public int count { get; set; } } 

我希望这会有用。 谢谢! 🙂