集約パイプラインとは何ですか？

Question

集約パイプラインとは何ですか？

Accepted Answer

**集約パイプライン**は、MongoDBの強力な**データ処理・分析**フレームワークです。ドキュメントを一連の**ステージ**に通し、各ステージがデータを変換します（フィルタリング、グループ化、計算）。SQLのGROUP BYおよび複雑な分析クエリに相当しますが、より柔軟です。

## パイプラインの概念：ステージがデータを変換する

```js
db.orders.aggregate([
  { $match: { status: "completed" } },          // 1. FILTER (like WHERE)
  { $group: {                                    // 2. GROUP and aggregate
      _id: "$customerId",                         //    group by customerId
      total: { $sum: "$amount" },                 //    sum amounts per customer
      count: { $sum: 1 }                          //    count orders
  }},
  { $sort: { total: -1 } },                       // 3. SORT by total
  { $limit: 10 }                                  // 4. top 10
]);
// documents flow through each stage; each stage's output feeds the next
```

ドキュメントは順序通りステージを通過します。各ステージがドキュメントを変換し、結果を次のステージに渡します。このパイプラインは、顧客ごとの合計を計算し、並べ替えて、上位10件を取得します。SQLのGROUP BYクエリのようなものです。

## 一般的なパイプラインステージ

```text
$match    → filter documents (like WHERE) — put EARLY to reduce data
$group    → group by a key and aggregate ($sum, $avg, $max, $min, $push, etc.)
$sort     → order documents
$project  → reshape documents (include/exclude/compute fields)
$limit / $skip → pagination
$unwind   → deconstruct an array field into multiple documents (one per element)
$lookup   → JOIN with another collection
$addFields → add computed fields
$count    → count documents
```

## $lookup — コレクションの結合

```js
// $lookup performs a left-outer JOIN to another collection
db.orders.aggregate([
  { $lookup: {
      from: "customers",
      localField: "customerId",
      foreignField: "_id",
      as: "customer"           // joined customer data added as an array field
  }}
]);
```

`$lookup`は結合を可能にします（MongoDBは通常、埋め込みでこれを避けます）。コレクションを結合する必要がある場合に便利です。

## $unwind — 配列を展開する

```js
// turn one document with an array into multiple documents (one per array element)
db.posts.aggregate([
  { $unwind: "$tags" },                           // one doc per tag
  { $group: { _id: "$tags", count: { $sum: 1 } } } // count posts per tag
]);
```

## なぜ重要なのか

集約パイプラインはMongoDBの最も強力で重要な機能の1つです。**データ分析、レポート、複雑な変換**のための主要なツールであり、基本的なクエリを超えた本格的なMongoDB活用には必須です。

パイプラインの**ステージベースのモデル**（ドキュメントが順次変換ステージを流れ、各ステージがフィルタリング、グループ化、再構築、または計算を行う）は、概念的に優れており、単純な`find`クエリでは実現できない高度なデータ処理を可能にします。これはSQLのGROUP BYおよび分析クエリに相当しますが、より柔軟で構成可能です。

一般的なステージを理解することが重要です。**`$match`**（フィルタリング、理想的にはデータを削減するため早めに実行）、**`$group`**（グループ化と`$sum`、`$avg`などでの集計 — 分析のコア）、**`$sort`/`$limit`**（並べ替えとページネーション）、**`$project`**（ドキュメントの再構築）、**`$unwind`**（配列をドキュメントに展開 — MongoDBの一般的な配列データ分析に重要）、**`$lookup`**（コレクションの結合 — MongoDBが通常避ける結合を可能にする）。これらはデータ処理の実際のツールキットをカバーしています。

パイプラインはレポート、分析、データ変換、複雑なクエリ（集計、結合、配列処理）を処理します。これらはアプリケーションで一般的なニーズです。

データ分析と複雑なクエリはあらゆるデータベースの重要な用途であり、集約パイプラインはMongoDBがそれに対して提供する強力で柔軟なメカニズムです（基本的なCRUDをはるかに超えています）。そのため、集約パイプライン — ステージモデルおよび主要なステージ（$match、$group、$sort、$project、$unwind、$lookup）を理解することは、分析、レポート、複雑なデータ変換のための本質的で頻繁に適用されるMongoDB知識であり、高度なMongoDBスキルの特徴であり、データベースから真の分析価値を得るための最も重要なMongoDBトピックの1つです。