$replaceRoot - Amazon DocumentDB

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

$replaceRoot

$replaceRoot 演算子は、ルートドキュメントを指定された埋め込みドキュメントに置き換えるために使用されます。これは、ネストされたドキュメントを最上位に昇格させたり、データ出力を再構築したりする場合に便利です。

パラメータ

  • newRoot: 既存のルートドキュメントを置き換える新しいルートドキュメント。

例 (MongoDB シェル)

この例では、顧客の注文から配送先住所情報を抽出する方法を示します。これは、配送ラベルまたは住所リストを生成するのに役立ちます。

サンプルドキュメントを作成する

db.orders.insertMany([ { "_id":1, "orderId": "ORD-2024-001", "customerId": "CUST-12345", "orderDate": "2024-01-15", "shippingAddress": { "name": "María García", "street": "123 Main St", "city": "Seattle", "state": "WA", "zipCode": "98101", "country": "USA" },"totalAmount": 149.99 }, { "_id":2, "orderId": "ORD-2024-002", "customerId": "CUST-67890", "orderDate": "2024-01-16", "shippingAddress": { "name": "Arnav Desai", "street": "456 Oak Ave", "city": "Portland", "state": "OR", "zipCode": "97201", "country": "USA" }, "totalAmount": 89.50 } ])

クエリの例

db.orders.aggregate([ { $replaceRoot: { newRoot: "$shippingAddress" } } ])

出力

{ name: 'María García', street: '123 Main St', city: 'Seattle', state: 'WA', zipCode: '98101', country: 'USA' }, { name: 'Arnav Desai', street: '456 Oak Ave', city: 'Portland', state: 'OR', zipCode: '97201', country: 'USA' }

コードの例

$replaceRoot コマンドを使用するコード例を表示するには、使用する言語のタブを選択します。

Node.js
const { MongoClient } = require('mongodb'); async function extractShippingAddresses() { const client = await MongoClient.connect('mongodb://<username>:<password>@<cluster-endpoint>:27017/?tls=true&tlsCAFile=global-bundle.pem&replicaSet=rs0&readPreference=secondaryPreferred&retryWrites=false'); const db = client.db('test'); const collection = db.collection('orders'); const result = await collection.aggregate([ { $replaceRoot: { newRoot: "$shippingAddress" } } ]).toArray(); console.log(result); await client.close(); } extractShippingAddresses();
Python
from pymongo import MongoClient def extract_shipping_addresses(): client = MongoClient('mongodb://<username>:<password>@<cluster-endpoint>:27017/?tls=true&tlsCAFile=global-bundle.pem&replicaSet=rs0&readPreference=secondaryPreferred&retryWrites=false') db = client['test'] collection = db['orders'] result = list(collection.aggregate([ { "$replaceRoot": { "newRoot": "$shippingAddress" } } ])) print(result) client.close() extract_shipping_addresses()