翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。
$addToSet
$addToSet 集計演算子は、各グループの指定された式から一意の値の配列を返します。$group ステージ内で使用して個別の値を蓄積し、重複を自動的に排除します。
パラメータ
例 (MongoDB シェル)
次の例は、 $addToSet演算子を使用して、顧客ごとに注文された一意の都市を収集する方法を示しています。
サンプルドキュメントを作成する
db.orders.insertMany([
{ _id: 1, customer: "Alice", city: "Seattle", amount: 100 },
{ _id: 2, customer: "Alice", city: "Portland", amount: 150 },
{ _id: 3, customer: "Bob", city: "Seattle", amount: 200 },
{ _id: 4, customer: "Alice", city: "Seattle", amount: 75 },
{ _id: 5, customer: "Bob", city: "Boston", amount: 300 }
]);
クエリの例
db.orders.aggregate([
{
$group: {
_id: "$customer",
cities: { $addToSet: "$city" }
}
}
]);
出力
[
{ _id: 'Bob', cities: [ 'Seattle', 'Boston' ] },
{ _id: 'Alice', cities: [ 'Seattle', 'Portland' ] }
]
ウィンドウ演算子の使用例 (MongoDB シェル)
バージョン 8.0.2 の新機能。
$addToSet 演算子は、$setWindowFieldsステージのウィンドウ演算子としても使用できます。このコンテキストでは、各ウィンドウのドキュメントに指定された式の一意の値の配列を返します。output フィールドで 演算子を指定し、オプションでwindowドキュメントを使用してウィンドウの境界を定義します。
でウィンドウ演算子として使用する場合$setWindowFields、 $addToSetは 100 MB の中間データに制限されます。この制限を超えるオペレーションはエラーを返します。
サンプルドキュメントを作成する
db.visits.insertMany([
{ _id: 1, customer: "Alice", day: 1, city: "Seattle" },
{ _id: 2, customer: "Alice", day: 2, city: "Portland" },
{ _id: 3, customer: "Alice", day: 3, city: "Seattle" },
{ _id: 4, customer: "Bob", day: 1, city: "Boston" },
{ _id: 5, customer: "Bob", day: 2, city: "Boston" }
]);
クエリの例
次の例では、ドキュメントを でパーティション化しcustomer、各パーティションを でソートしてday、パーティションの先頭から現在のドキュメントまでの一意のcity値のセットを返します。
db.visits.aggregate([
{
$setWindowFields: {
partitionBy: "$customer",
sortBy: { day: 1 },
output: {
citiesSoFar: {
$addToSet: "$city",
window: { documents: ["unbounded", "current"] }
}
}
}
}
]);
出力
[
{ "_id": 1, "customer": "Alice", "day": 1, "city": "Seattle", "citiesSoFar": [ "Seattle" ] },
{ "_id": 2, "customer": "Alice", "day": 2, "city": "Portland", "citiesSoFar": [ "Portland", "Seattle" ] },
{ "_id": 3, "customer": "Alice", "day": 3, "city": "Seattle", "citiesSoFar": [ "Portland", "Seattle" ] },
{ "_id": 4, "customer": "Bob", "day": 1, "city": "Boston", "citiesSoFar": [ "Boston" ] },
{ "_id": 5, "customer": "Bob", "day": 2, "city": "Boston", "citiesSoFar": [ "Boston" ] }
]
各ドキュメントはcitiesSoFar、最初から現在のドキュメントまでのパーティション内の一意のcity値のセットである で拡張されます。アキュムレータ形式と同様に、返される配列の値の順序は保証されません。
コードの例
$addToSet 演算子を使用するコード例を表示するには、使用する言語のタブを選択します。次の例は、アキュムレータの使用 ( の場合$group) とウィンドウ演算子の使用 ( の場合) の両方を示しています$setWindowFields。
- Node.js
-
const { MongoClient } = require('mongodb');
async function example() {
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');
// Accumulator usage: collect unique values per group
const orders = db.collection('orders');
await orders.insertMany([
{ _id: 1, customer: "Alice", city: "Seattle", amount: 100 },
{ _id: 2, customer: "Alice", city: "Portland", amount: 150 },
{ _id: 3, customer: "Bob", city: "Seattle", amount: 200 },
{ _id: 4, customer: "Alice", city: "Seattle", amount: 75 },
{ _id: 5, customer: "Bob", city: "Boston", amount: 300 }
]);
const accumulatorResult = await orders.aggregate([
{
$group: {
_id: "$customer",
cities: { $addToSet: "$city" }
}
}
]).toArray();
console.log('Accumulator result:', accumulatorResult);
// Window operator usage: running set of unique values within each partition
const visits = db.collection('visits');
await visits.insertMany([
{ _id: 1, customer: "Alice", day: 1, city: "Seattle" },
{ _id: 2, customer: "Alice", day: 2, city: "Portland" },
{ _id: 3, customer: "Alice", day: 3, city: "Seattle" },
{ _id: 4, customer: "Bob", day: 1, city: "Boston" },
{ _id: 5, customer: "Bob", day: 2, city: "Boston" }
]);
const windowResult = await visits.aggregate([
{
$setWindowFields: {
partitionBy: "$customer",
sortBy: { day: 1 },
output: {
citiesSoFar: {
$addToSet: "$city",
window: { documents: ["unbounded", "current"] }
}
}
}
}
]).toArray();
console.log('Window result:', windowResult);
await client.close();
}
example();
- Python
-
from pymongo import MongoClient
def example():
client = MongoClient('mongodb://<username>:<password>@<cluster-endpoint>:27017/?tls=true&tlsCAFile=global-bundle.pem&replicaSet=rs0&readPreference=secondaryPreferred&retryWrites=false')
db = client['test']
# Accumulator usage: collect unique values per group
orders = db['orders']
orders.insert_many([
{ '_id': 1, 'customer': 'Alice', 'city': 'Seattle', 'amount': 100 },
{ '_id': 2, 'customer': 'Alice', 'city': 'Portland', 'amount': 150 },
{ '_id': 3, 'customer': 'Bob', 'city': 'Seattle', 'amount': 200 },
{ '_id': 4, 'customer': 'Alice', 'city': 'Seattle', 'amount': 75 },
{ '_id': 5, 'customer': 'Bob', 'city': 'Boston', 'amount': 300 }
])
accumulator_result = list(orders.aggregate([
{
'$group': {
'_id': '$customer',
'cities': { '$addToSet': '$city' }
}
}
]))
print('Accumulator result:', accumulator_result)
# Window operator usage: running set of unique values within each partition
visits = db['visits']
visits.insert_many([
{ '_id': 1, 'customer': 'Alice', 'day': 1, 'city': 'Seattle' },
{ '_id': 2, 'customer': 'Alice', 'day': 2, 'city': 'Portland' },
{ '_id': 3, 'customer': 'Alice', 'day': 3, 'city': 'Seattle' },
{ '_id': 4, 'customer': 'Bob', 'day': 1, 'city': 'Boston' },
{ '_id': 5, 'customer': 'Bob', 'day': 2, 'city': 'Boston' }
])
window_result = list(visits.aggregate([
{
'$setWindowFields': {
'partitionBy': '$customer',
'sortBy': { 'day': 1 },
'output': {
'citiesSoFar': {
'$addToSet': '$city',
'window': { 'documents': ['unbounded', 'current'] }
}
}
}
}
]))
print('Window result:', window_result)
client.close()
example()
