/ /

/ /

`$lookup` ステージ（Atlas Data Federation）

Lookups を使用すると、データベース上の「結合された」コレクションのドキュメントをフィルターして、相関情報をより簡単にプロセシングできます。

MongoDBフェデレーティッドデータベースインスタンスでは、$lookup を使用して、同じデータベースまたは別のデータベースからシャーディングされたコレクションまたはシャーディングされていないコレクションの左外部結合を実行できます。$lookup は、Atlas 上のフェデレーティッドデータ保存、 AWS S3、および HTTP または HTTPS のいずれかのフェデレーティッドデータ保存のコレクションに適用できます。

注意

シャーディングされたコレクションの場合、$lookup はMongoDB 5.1 以降を実行中のAtlas クラスターでのみ使用できます。

構文

$lookup構文については、MongoDB サーバーマニュアルを参照してください。

Data Federation では、from の$lookup フィールドは次の代替構文をとります。これにより、任意のデータベース名と必須のコレクション名を含むオブジェクトを指定できます。

{
  $lookup: {
    localField: "<fieldName>",
    from: <collection-to-join>|{db: <db>, coll: <collection-to-join>},
    foreignField: "<fieldName>",
    as: "<output-array-field>",
  }
}

{
  $lookup: {
    from: <collection to join>|{db: <db>, coll: <collection-to-join>},
    let: { <var_1>: <expression>, …, <var_n>: <expression> },
    pipeline: [ <pipeline to execute on the collection to join> ],
    as: <output array field>
  }
}

`from` フィールドオブジェクト

フィールド	タイプ	説明	必要性
`db`	string	データベース名。データベース名を指定すると、Data Federation は指定されたデータベース内のコレクションからデータを読み取ります。コマンドが動作しているデータベースとは異なるデータベース名を指定する場合は、ネストされたすべての$lookupステージでもこのデータベース名を指定する必要があります。 $lookupステージ内でデータベース名を指定しない場合、ステージ内のコレクションは、最も近い親$lookupステージで指定されたデータベース名（存在する場合）、またはコマンドが動作しているデータベースの名前を継承します。	条件付き
`coll`	string	コレクション名。	必須

例

たとえば、 sourceDB1 、 sourceDB2 、 sourceDB3という名前の 3 つのデータベースがあり、次のコレクションが含まれているとします。

db.orders.insertMany([
  { "_id" : 1, "item" : "almonds", "price" : 12, "quantity" : 2 },
  { "_id" : 2, "item" : "pecans", "price" : 20, "quantity" : 1 },
  { "_id" : 3  }
])

db.catalog.insertMany([
  { "_id" : 1, "sku" : "almonds", "description": "product 1" },
  { "_id" : 2, "sku" : "bread", "description": "product 2" },
  { "_id" : 3, "sku" : "cashews", "description": "product 3" },
  { "_id" : 4, "sku" : "pecans", "description": "product 4" },
  { "_id" : 5, "sku": null, "description": "Incomplete" },
  { "_id" : 6 }
])

db.warehouses.insertMany([
  { "_id" : 1, "stock_item" : "almonds", "warehouse": "A", "instock" : 120 },
  { "_id" : 2, "stock_item" : "pecans", "warehouse": "A", "instock" : 70 },
  { "_id" : 3, "stock_item" : "cashews", "warehouse": "B", "instock" : 60 },
  { "_id" : 4, "stock_item" : "bread", "warehouse": "B", "instock" : 80 },
  { "_id" : 5, "stock_item" : "cookies", "warehouse": "A", "instock" : 80 }
])

次の例では、 $lookup集計ステージを使用して、1 つのコレクションのドキュメントを他のデータベース内のコレクションのドキュメントと結合します。

基本的な例

sourceDB1.ordersコレクションに対する次の集計操作は、 ordersコレクションのitemフィールドとcatalogのskuフィールドを使用して、 ordersコレクションのドキュメントとsourceDB2.catalogコレクションのドキュメントを結合します。コレクション：

db.getSiblingDB("sourceDB1").orders.aggregate(
  {
    $lookup: {
      from: { db: "sourceDB2", coll: "catalog" },
      localField: "item",
      foreignField: "sku",
      as: "inventory_docs"
    }
  }
)

ネストされた例

sourceDB1.ordersコレクションに対する次の集計操作は、orders sourceDB2.catalogsourceDB3.warehousesコレクションのitem ordersフィールドを使用して、コレクションのドキュメントとsku catalogコレクションのドキュメント、およびコレクションのドキュメントを結合します。コレクションのフィールドと、コレクションのフィールドとフィールドstock_iteminstockwarehouses

db.getSiblingDB("sourceDB1").orders.aggregate(
  [
    {
      $lookup: {
        from: db: "sourceDB2", coll: "catalog",
        let: { "order_sku": "$item" },
        pipeline: [
          {
            $match: {
              $expr: {
                $eq: ["$sku", "$$order_sku"]
              }
            }
          },
          {
            $lookup: {
              from: db: "sourceDB3", coll: "warehouses",
              pipeline: [
                {
                  $match: {
                    $expr:{
                      $eq : ["$stock_item", "$$order_sku"]
                    }
                  }
                },
                {
                  $project : { "instock": 1, "_id": 0}
                }
              ],
              as: "wh"
            }
          },
          { "$unwind": "$wh" },
          {
            $project : { "description": 1, "instock": "$wh.instock", "_id": 0}
          }
        ],
        as: "inventory"
      },
    },
  ]
)

戻る

$collStats

$merge

注意

構文

from フィールド オブジェクト

例

基本的な例

ネストされた例

`from` フィールドオブジェクト