Mongodb: Wybierz górne N wierszy z każdej grupy

Question

Używam mongodb na mojej platformie blogów, gdzie użytkownicy mogą tworzyć własne blogi. Wszystkie wpisy ze wszystkich blogów znajdują się w zbiorze wpisów. Dokument wpisu wygląda następująco:

{ 
    'blog_id':xxx, 
    'timestamp':xxx, 
    'title':xxx, 
    'content':xxx 
} 

Jak wskazuje pytanie, czy istnieje sposób wyboru, powiedzmy, ostatnie 3 wpisy dla każdego bloga?

Answer 1

Jedynym sposobem, aby to zrobić w podstawowej Mongo, czy można żyć z dwóch rzeczy:

• dodatkowe pole w dokumencie wejścia, nazwijmy to „wiek”
• nowy wpis w blogu odbywających dodatkowa zmiana

Jeśli tak, oto jak to zrobić:

1. Po utworzeniu ne Włóż do zwykłej wkładki, a następnie wykonaj tę aktualizację, aby zwiększyć wiek wszystkich wpisów (w tym tego, który właśnie wstawiłeś dla tego bloga):

   db.entries.update ({blogi: BLOG_ID}, {wiek: { $ inc: 1}}, false, true)

2. Podczas odpytywania, należy użyć następującego zapytania, które zwróci ostatnie 3 wpisy dla każdego bloga:

   db.entries.find ({wiek: {$ LTE: 3}, datownik {$ gte: STARTOFMONTH, $ LT. ENDOFMONTH}}), rodzaj ({blog_id: 1, wiek: 1})

Należy pamiętać, że to rozwiązanie jest w rzeczywistości bezpieczne dla współbieżności (brak wpisów o zduplikowanych grupach wiekowych).

Answer 2

Jest to możliwe z grupą (agregacja), ale spowoduje to skanowanie w pełnym widoku.

Czy naprawdę potrzebujesz dokładnie 3 lub czy możesz ustawić limit ... np .: maksymalnie 3 posty z ostatniego tygodnia/miesiąca?

Answer 3

Ta odpowiedź używając mapy zmniejszyć przez drcosta z innym pytaniem wystarczyły

In mongo, how do I use map reduce to get a group by ordered by most recent

mapper = function() { 
    emit(this.category, {top:[this.score]}); 
} 

reducer = function (key, values) { 
    var scores = []; 
    values.forEach(
    function (obj) { 
     obj.top.forEach(
     function (score) { 
      scores[scores.length] = score; 
     }); 
    }); 
    scores.sort(); 
    scores.reverse(); 
    return {top:scores.slice(0, 3)}; 
} 

function find_top_scores(categories) { 
    var query = []; 
    db.top_foos.find({_id:{$in:categories}}).forEach(
    function (topscores) { 
     query[query.length] = { 
     category:topscores._id, 
     score:{$in:topscores.value.top} 
     }; 
    }); 
    return db.foo.find({$or:query}); 

Answer 4

Musisz najpierw uporządkować dokumenty w kolekcji przez pola blog_id i timestamp, zrób wstępny grupa, która tworzy tablicę oryginalnych dokumentów w porządku malejącym. Następnie możesz wyciąć tablicę z dokumentami, aby zwrócić pierwsze 3 elementy.

Intuicja może być stosowana w tym przykładzie:

db.entries.aggregate([ 
    { '$sort': { 'blog_id': 1, 'timestamp': -1 } }, 
    {  
     '$group': { 
      '_id': '$blog_id', 
      'docs': { '$push': '$$ROOT' }, 
     } 
    }, 
    { 
     '$project': { 
      'top_three': { 
       '$slice': ['$docs', 3] 
      } 
     } 
    } 
])