集計によるデータの変換

集計操作と検索操作の比較

次の表は、検索操作が実行できるさまざまなタスクを示し、それらを集計操作と比較しています。集計フレームワークは、データを変換および操作するための拡張機能を提供します。

制限

集計操作を実行する際には、次の制限を考慮してください。

• 返されたドキュメントは、 BSONドキュメントサイズの制限である16メガバイトに違反することはできません。

• パイプライン ステージには、デフォルトで 100 メガバイトのメモリ制限があります。この制限を超えるには、true の値を allowDiskUse() メソッドに渡し、そのメソッドを aggregate() にチェーンします。

• $graphLookup 演算子には、 MB100 の厳格なメモリ制限があり、allowDiskUse() メソッドに渡される値を無視します。

ドキュメントのフィルタリング、グループ化、カウント

このコード例では、ニューヨークの各地区のケーキの数のカウントを生成します。そのためには、aggregate() メソッドを呼び出し、集計パイプラインをステージのリストとして渡します。コードでは、次の Aggregatesヘルパーメソッドを使用してこれらのステージを構築します。

• filter(): $match ステージを構築して、cuisine の値が であるドキュメントをフィルタリングします"Bakery"

• group(): $group ステージを構築して、一致するドキュメントをborough フィールドでグループ化し、個別の 値ごとにドキュメントの数を蓄積します

val pipeline = Seq(Aggregates.filter(Filters.equal("cuisine", "Bakery")),
                   Aggregates.group("$borough", Accumulators.sum("count", 1))
)
collection.aggregate(pipeline)
          .subscribe((doc: Document) => println(doc.toJson()),
                    (e: Throwable) => println(s"There was an error: $e"))

{"_id": "Brooklyn", "count": 173}
{"_id": "Queens", "count": 204}
{"_id": "Bronx", "count": 71}
{"_id": "Staten Island", "count": 20}
{"_id": "Missing", "count": 2}
{"_id": "Manhattan", "count": 221}

集計の説明

MongoDB が操作を実行する方法に関する情報を表示するには、 MongoDBクエリ プランナーにそれを説明するように指示できます。 MongoDB が操作 を説明すると、実行プランとパフォーマンス統計が返されます。実行プランは、 MongoDB が操作を完了できる潜在的な方法です。 MongoDB に操作を説明するよう指示すると、 MongoDBが実行したプランと拒否された実行プランの両方がデフォルトで返されます。

集計操作explain() aggregate()を説明するには、 メソッドを メソッドに連鎖させます。冗長レベルをexplain() に渡すことで、メソッドが返す情報のタイプと量が変更されます。冗長 の詳細については、 MongoDB Serverマニュアルの「 冗長モード 」を参照してください。

次の例では、 MongoDBExplainVerbosity.EXECUTION_STATS explain()に、前述の フィルター、グループ、ドキュメントの例の集計操作を説明するように指示します。このコードでは、 の冗長値が メソッドに渡されます。これにより、 メソッドは、当選プランの実行を説明する統計を返すように構成されます。

val pipelineToExplain = Seq(Aggregates.filter(Filters.equal("cuisine", "Bakery")),
                   Aggregates.group("$borough", Accumulators.sum("count", 1))
)
collection.aggregate(pipelineToExplain)
          .explain(ExplainVerbosity.EXECUTION_STATS)
          .subscribe((doc: Document) => println(doc.toJson()),
                    (e: Throwable) => println(s"There was an error: $e"))

{"explainVersion": "2", "queryPlanner": {"namespace": "sample_restaurants.restaurants",
"indexFilterSet": false, "parsedQuery": {"cuisine": {"$eq": "Bakery"}}, "queryHash": "865F14C3",
"planCacheKey": "0FC225DA", "optimizedPipeline": true, "maxIndexedOrSolutionsReached": false,
"maxIndexedAndSolutionsReached": false, "maxScansToExplodeReached": false, "winningPlan":
{"queryPlan": {"stage": "GROUP", "planNodeId": 3, "inputStage": {"stage": "COLLSCAN",
"planNodeId": 1, "filter": {"cuisine": {"$eq": "Bakery"}}, "direction": "forward"}},
...}

Atlas 全文検索の実行

1 つ以上のフィールドの全文検索を指定するには、$searchパイプラインステージを作成します。 Scalaドライバーは、このステージを作成するための Aggregates.search()ヘルパーメソッドを提供します。 search() メソッドには次の引数が必要です。

• SearchOperator インスタンス: 検索するフィールドとテキストを指定します。

• SearchOptions インスタンス: 全文検索をカスタマイズするオプションを指定します。使用する Atlas Searchインデックスの名前に index オプションを設定する必要があります。

この例では、次のアクションを実行するためのパイプラインステージを作成しています。

• nameフィールドで"Salt" という単語を含むテキストを検索

• 一致するドキュメントの _id と name の値のみを予測

val operator = SearchOperator.text(SearchPath.fieldPath("name"), "Salt")
val options = searchOptions().index("<search index name>")
val pipeline = Seq(Aggregates.search(operator, options),
                   Aggregates.project(Projections.include("name")))
collection.aggregate(pipeline)
          .subscribe((doc: Document) => println(doc.toJson()),
                    (e: Throwable) => println(s"There was an error: $e"))

{"_id": {"$oid": "..."}, "name": "Fresh Salt"}
{"_id": {"$oid": "..."}, "name": "Salt & Pepper"}
{"_id": {"$oid": "..."}, "name": "Salt + Charcoal"}
{"_id": {"$oid": "..."}, "name": "A Salt & Battery"}
{"_id": {"$oid": "..."}, "name": "Salt And Fat"}
{"_id": {"$oid": "..."}, "name": "Salt And Pepper Diner"}

MongoDB Server マニュアル

このガイドで説明されているトピックについて詳しくは、 MongoDB Serverマニュアルの次のページ を参照してください。

• 式演算子の完全なリストを表示するには、「集計演算子 」を参照してください。

• 集計パイプラインの組み立てと例については、「集計パイプライン 」を参照してください。

• パイプライン ステージの作成の詳細については、「集計ステージ 」を参照してください。

• MongoDB 操作の説明の詳細については、「出力とクエリ プランの説明 」を参照してください。

API ドキュメント

このガイドで説明するメソッドとタイプの詳細については、次の API ドキュメントを参照してください。

• Aggregate()

• 集計

• explain()