Visualizações materializadas sob demanda

Indexes

As visualizações padrão usam os índices da coleta subjacente. Como resultado , você não pode criar, eliminar ou reconstruir índices diretamente em uma visualização , nem obter uma lista de índices na visualização.

Você pode criar índices diretamente em visualizações materializadas sob demanda porque eles são armazenados em disco.

Desempenho

As visualizações materializadas sob demanda fornecem melhor desempenho de leitura do que as visualizações porque são lidas do disco em vez de computadas como partes da consulta. Esse benefício de desempenho aumenta com base na complexidade do pipeline e no tamanho dos dados que estão sendo agregados.

1. Definir a visão materializada on-demand

A função updateMovieStats a seguir define uma visualização materializada movieYearStats que contém a contagem e a classificação média do IMDb de filmes por ano. A função aceita um parâmetro startYear para atualizar as estatísticas de filmes lançados a partir desse ano.

updateMovieStats = function(startYear) {
   db.movies.aggregate( [
      { $match: { year: { $gte: startYear } } },
      { $group: {
           _id: "$year",
           movieCount: { $sum: 1 },
           avgRating: { $avg: "$imdb.rating" }
      } },
      { $merge: { into: "movieYearStats", whenMatched: "replace" } }
   ] );
};

• O estágio $match filtro os filmes para processar apenas aqueles com um valor year maior ou igual a startYear.

• O estágio $group agrupa filmes por year. Os documentos gerados por esse estágio têm o formato:

  { "_id" : <year>, "movieCount" : <num>, "avgRating" : <num> }

• O estágio $merge escreve o resultado na collection movieYearStats.

  O estágio corresponde ao campo _id e verifica se cada resultado de agregação corresponde a um documento existente:

  • Quando há uma correspondência (ou seja, um documento com o mesmo ano já existe na coleção), o estágio substitui o documento existente pelo documento dos resultados da agregação.

  • Quando não há uma correspondência, o estágio insere o documento dos resultados da agregação na coleção (o comportamento padrão quando não correspondido).

2. Realizar execução inicial

Para a execução inicial, passe um ano de início para preencher movieYearStats com dados daquele ano em diante:

updateMovieStats(2015);

Após a execução inicial, o db.movieYearStats.find().sort( { _id: 1 } ) retorna documentos como o seguinte:

{ "_id" : 2015, "movieCount" : <num>, "avgRating" : <num> }
{ "_id" : 2016, "movieCount" : <num>, "avgRating" : <num> }
{ "_id" : 2017, "movieCount" : <num>, "avgRating" : <num> }

3. Atualizar visualização materializada

Suponha que um novo filme seja adicionado à coleção movies para 2016:

db.movies.insertOne( {
   title: "Grove Test Movie",
   year: 2016,
   imdb: { rating: 7.5, votes: 500 }
} )

Para atualizar movieYearStats para 2016 em diante, execute a função com um startYear de 2016:

updateMovieStats(2016);

O movieYearStats atualizado reflete o novo filme na coleção movies. db.movieYearStats.find().sort( { _id: 1 } ) retorna:

{ "_id" : 2015, "movieCount" : <num>, "avgRating" : <num> }
{ "_id" : 2016, "movieCount" : <num>, "avgRating" : <num> }
{ "_id" : 2017, "movieCount" : <num>, "avgRating" : <num> }