$shardedDataDistribution（集計ステージ）

定義

$shardedDataDistribution

バージョン6.0.3の新機能。

シャーディングされたコレクション内のデータの分散に関する情報を返します。

注意

この集計ステージはmongosでのみ使用できます。

この集計ステージはadminデータベースで実行する必要があります。ユーザーにはshardedDataDistribution特権アクションが必要です。

構文

shardedDataDistribution ステージの構文は次のとおりです。

db.aggregate( [   { $shardedDataDistribution: { } }] )

出力フィールド

$shardedDataDistributionステージは、データベース内のシャーディングされた各コレクションのドキュメントの配列を出力します。これらのドキュメントには、次のフィールドが含まれています。

フィールド名	データ型	説明
`ns`	string	シャーディングされたコレクションの名前空間。
`shards`	配列	各シャードのデータ配信情報を含むコレクション内のシャード。
`shards.numOrphanedDocs`	integer	シャード内の孤立したドキュメントの数。
`shards.numOwnedDocuments`	integer	シャードが所有するドキュメントの数。
`shards.ownedSizeBytes`	integer	非圧縮時にシャードが所有するドキュメントのサイズ（バイト単位）。
`shards.orphanedSizeBytes`	integer	シャード内の孤立したドキュメントの非圧縮時のサイズ（バイト単位）。

動作

Wired Tigerストレージエンジンを使用して mongod を不正にシャットダウンした後、$shardedDataDistribution によって報告されるサイズとカウントの統計が不正確になる可能性があります。

ドリフトの量は、チェックポイントからクリーンシャットダウンまでの間に実行された挿入、アップデート、または削除操作の数によって異なります。チェックポイントは通常、60 秒ごとに発現します。ただし、デフォルト以外の --syncdelay 設定で実行されている mongod インスタンスでは、チェックポイントの頻度が増減する可能性があります。

不正なシャットダウン後に統計を復元するには、mongod の各コレクションに対して validate を実行します。

不正なシャットダウン後:

validate は、collStats 出力のカウント統計を最新の値でアップデートします。
collStats 出力で挿入または削除されたドキュメントの数などのその他の統計は推定値です。

例

すべてのシャーディングされたデータディストリビューションを返す

すべてのシャーディングされたデータ分布のメトリクスを返すには、次のコマンドを実行します。

db.aggregate([   { $shardedDataDistribution: { } }])

出力例:

[  {    "ns": "test.names",    "shards": [      {        "shardName": "shard-1",        "numOrphanedDocs": 0,        "numOwnedDocuments": 6,        "ownedSizeBytes": 366,        "orphanedSizeBytes": 0      },      {        "shardName": "shard-2",        "numOrphanedDocs": 0,        "numOwnedDocuments": 6,        "ownedSizeBytes": 366,        "orphanedSizeBytes": 0      }    ]  }]

特定のシャードのメトリクスを返す

特定のシャードのシャーディングされたデータ分布のメトリクスを返すには、次のコマンドを実行します。

db.aggregate([   { $shardedDataDistribution: { } },   { $match: {  "shards.shardName": "<name of the shard>" } }])

名前空間のメトリクスを返す

名前空間のシャーディングされたデータ配信データを返すには、次のコマンドを実行します。

db.aggregate([   { $shardedDataDistribution: { } },   { $match: {  "ns": "<database>.<collection>" } }])

孤立したドキュメントが存在しないことを確認

MongoDB 6.0.3以降、 $shardedDataDistributionステージを使用して集計を実行すると、孤立したドキュメントが残っていないことを確認できます。

db.aggregate([   { $shardedDataDistribution: { } },   { $match: { "ns": "<database>.<collection>" } }])

$shardedDataDistribution には、次のような出力があります。

[  {    "ns": "test.names",    "shards": [      {        "shardName": "shard-1",        "numOrphanedDocs": 0,        "numOwnedDocuments": 6,        "ownedSizeBytes": 366,        "orphanedSizeBytes": 0      },      {        "shardName": "shard-2",        "numOrphanedDocs": 0,        "numOwnedDocuments": 6,        "ownedSizeBytes": 366,        "orphanedSizeBytes": 0      }    ]  }]

クラスター内の各シャードで"numOrphanedDocs"が0であることを確認します。

MongoDB Node.jsドライバーを使用して $shardedDataDistribution ステージを集計パイプラインに追加するには、パイプラインオブジェクトで $shardedDataDistribution 演算子を使用します。

すべてのシャーディングされたデータ分散メトリクスを返す

次の例では、シャーディングされたコレクション内のデータの分布に関する情報を返すパイプラインステージを作成しています。次に、この例では集計パイプラインを実行します。

const pipeline = [{$shardedDataDistribution: {} }];
const adminDb = client.db("admin");const cursor = adminDb.aggregate(pipeline);return cursor;

特定のシャードのメトリクスを返す

次の例では、特定のシャードのデータの分散に関する情報を返します。

const pipeline = [  { $shardedDataDistribution: {} },  { $match: {"shards.shardName": 'atlas-kn29y8-shard-0'} }];
const adminDb = client.db("admin");const cursor = adminDb.aggregate(pipeline);return cursor;

名前空間のメトリクスを返す

次の例では、特定の名前空間のデータの分布に関する情報を返します。

const pipeline = [  { $shardedDataDistribution: {} },  { $match: {"ns": "sample_mflix.movies"} }];
const adminDb = client.db("admin");const cursor = adminDb.aggregate(pipeline);return cursor;

戻る

$setWindowFields

$skip