オンデマンドのマテリアライズドビュー

Indexes

標準ビューでは、基になるコレクションのインデックスが使用されます。そのため、標準ビューでインデックスを直接作成、削除、再構築したり、ビューでインデックスのリストを取得したりすることはできません。

オンデマンドのマテリアライズドビューはディスクに保存されるため、インデックスを直接作成できます。

パフォーマンス

オンデマンドのマテリアライズドビューは、クエリの一部として計算されるのではなくディスクから読み取られるため、標準ビューよりも読み取りパフォーマンスが向上します。このパフォーマンス上の利点は、パイプラインの複雑さと集約されるデータのサイズに応じて大きくなります。

On MongoDB Atlas, Atlas Stream Processing can also maintain a streaming materialized view that updates continuously as source data changes. To learn more, see Streaming Materialized Views.

1. オンデマンドのマテリアライズドビューを定義する

次の updateMovieStats 関数は、年別の映画の IMDb 評価のカウントと平均を含む movieYearStats マテリアライズドビューを定義します。この関数は、その年以降に公開された映画の統計を更新するための startYear パラメータを受け入れます。

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" } }
   ] );
};

• $matchステージは、year 値が startYear 以上の映画のみを処理するようにフィルターします。

• $groupステージでは、映画をyearでグループ化します。このステージで出力されるドキュメントは、以下のような形式になります。

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

• $merge ステージは出力を movieYearStats コレクションに書き込みます。

  このステージは _id フィールドで 一致し、各集計結果が既存のドキュメントと 一致するかどうかを確認します。

  • 一致がある場合（つまり、同じ年を持つドキュメントがコレクション内に既に存在する場合）、このステージは既存のドキュメントを集計結果のドキュメントに置き換えます。

  • 一致しない場合、ステージは集計結果からドキュメントをコレクションに挿入します（一致しない場合のデフォルトの動作）。

2. 初期実行の実行

初回の実行では、開始年を渡して、その年以降のデータを movieYearStats に入力します。

updateMovieStats(2015);

初回の実行後、db.movieYearStats.find().sort( { _id: 1 } ) は次のようなドキュメントを返します。

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

3. マテリアライズドビューのアップデート

新しい映画が 2016 の movies コレクションに追加されると仮定します。

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

2016 以降の movieYearStats を更新するには、startYear を 2016 に設定して関数を実行します。

updateMovieStats(2016);

更新された movieYearStats には、movies コレクションの新作映画が反映されています。db.movieYearStats.find().sort( { _id: 1 } ) は以下を返します。

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