Necesitas conseguir 10 artículos de cada grupo. Ordenar por ID descendente y agrupar por categoría
public class Item { public string Id { get; set ; } public string Name { get ; set ; } public string Category { get ; set ; } }Intenté algo como esto.
var data = Collection.AsQueryable() .OrderByDescending(o=> o.Id) .GroupBy(x => x.Category) .Select(g => new { GroupName = g.Key, Items = g.Take(10).ToList() });Pero tengo una excepción como esta
System.NotSupportedException: el método especificado no es compatible. en MongoDB.Driver.Linq.Processors.AccumulatorBinder.GetAccumulatorArgument(Nodo de expresión)
Utilice Aggregation Framework en su lugar. El proveedor MongoDB LINQ se basa en él.
Puede obtener 10 elementos de cada grupo ordenados por Id de forma descendente con la siguiente consulta:
db.items.aggregate([ { "$sort": { "Id": -1 } }, { "$group": { "_id": "$Category", "Items": { "$push": "$$ROOT" } } }, { "$project": { "_id": 0, "GroupName": "$_id", "Items": { "$slice": ["$Items", 10] } } } ])El código C# será el siguiente:
// models public class Item { public string Id { get; set; } public string Name { get; set; } public string Category { get; set; } } public class ItemsGroup { public string GroupName { get; set; } public Item[] Items { get; set; } } // query var collection = db.GetCollection<Item>("Items"); IAggregateFluent<ItemsGroup> result = collection.Aggregate() .SortByDescending(o => o.Id) .Group(BsonDocument.Parse("{ _id: '$Category', Items: { '$push': '$$ROOT'}}")) .Project<ItemsGroup>(BsonDocument.Parse("{ _id: 0, GroupName: '$_id', Items: { $slice: ['$Items', 10]}}")); List<ItemsGroup> groups = result.ToList(); Esta consulta, sin embargo, puede tener un problema. Si hay miles de elementos para cada grupo, supongo que la fase de grupos los mantendrá a todos en la matriz temporal Items , mientras que solo queremos 10.
Si la cantidad de claves que se agrupan no es grande, sería mejor hacer $búsqueda para cada grupo en lugar de colocar todo en una matriz y luego $cortarla. Esto se puede lograr mediante la siguiente consulta:
aggregate([ { "$group": { "_id": "$Category" } }, { "$lookup": { "from": "Items", "let": { "c": "$_id" }, "as": "Items" "pipeline": [ { "$match": { "$expr": { "$eq": ["$Category", "$$c"] } } }, { "$sort": { "Id": -1 } }, { "$limit": 10 } ], } }, { "$project": { "_id": 0, "GroupName": "$_id", "Items": 1 } } ])En código C#, sería como:
BsonArray pipeline = new BsonArray { BsonDocument.Parse("{ $match: { $expr: { $eq: ['$Category', '$$c']} } }"), BsonDocument.Parse("{ $sort: { Id: -1 } }"), BsonDocument.Parse("{ $limit: 10 }") }; BsonDocument lookup = new BsonDocument("$lookup", new BsonDocument("from", "Items") .Add("let", new BsonDocument("c", "$_id")) .Add("pipeline", pipeline) .Add("as", "Items") ); IAggregateFluent<ItemsGroup> result = collection.Aggregate() .Group(BsonDocument.Parse("{ _id: '$Category' }")) .AppendStage<object>(lookup) .Project<ItemsGroup>("{ _id: 0, GroupName: '$_id', Items: 1 }"); List<ItemsGroup> groups = result.ToList();