在Mongodb中按日期聚合
本文关键字:日期 Mongodb | 更新日期: 2023-09-27 18:17:45
我正在编写一个需要按日期分组的功能。以下是我目前的做法:
//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,起始日期和结束日期;我需要搜索与这些过滤器匹配的集合,并按日期对结果进行分组。换句话说,我需要实现的结果是一个列表(例如,12/10/2015 - count是5,13/10/2015 - count是2)。StartDate和EndDate是DateTime的类型。
c#是我使用的编程语言,目前,我写的方式是:
var builder = Builders<MyCollection>.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<CustomAggregateResult> grouped = group.Select(g => BsonSerializer.Deserialize<CustomAggregateResult>(g)).OrderBy(g => g.Date).ToList();
很明显,这段代码失败的地方是分组部分。在我的情况下,最理想的是按Date而不是DateTime分组。我已经阅读了组文档和一些类似的线程在这里,但不幸的是,我不能得到它的工作。我的一个尝试是按照文档中的建议去做。原始mongo查询将是:
db.mycollection.aggregate(
[
{
$group : {
_id : { month: { $month: "$createddate" }, day: { $dayOfMonth: "$createddate" }, year: { $year: "$createddate" } },
count: { $sum: 1 }
}
}
))
我省略了$match只是为了让这部分工作。我得到的例外是"不能从BSON类型对象转换为日期"。
总之,我当前的代码工作,但"组"基于DateTime(而不仅仅是日期),它结束了一个特定的一天的单独计数。我很好奇这是否可以实现。未知对我来说是最重要的部分,因为我还没有弄清楚如何做到这一点。(即使在原始mongo查询中也是如此)。
只是一些额外的信息来澄清,我对c#中的datetime对象有以下数据注释(不确定这是否有影响):
[BsonDateTimeOptions(Representation = BsonType.Document)]
public DateTime CreatedDate {get; set; }
我想到的一个解决方案是,是否有可能在飞行中投影"createddate"字段并将其格式为"Y-m-d",并根据投影字段进行分组。
我试着添加尽可能多的细节,我可以和我所做的工作到目前为止,只是为了使它更清楚。我希望这没有引起任何困惑。如果能帮助我达到我想要的结果,我将不胜感激。谢谢!
我能够修复它,根据@ chrisdam的评论。再次感谢!
我把解决方案写在下面,以防万一,如果有人遇到同样的问题。
我改变了我的查询,所以我变成了:
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<RootObject>(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; }
}
我希望这将是有用的。谢谢!:)