reshardCollection（データベースコマンド）

リシャーディングの制限

• If the collection uses Atlas Search, the search index becomes unavailable after the operation completes. To restore it, manually rebuild the search index.

• Queryable 暗号化を使用するコレクションはサポートされていません。

初期化フェーズ

初期化フェーズ中に、リシャーディング コーディネーターはシャーディングされたコレクションの新しいデータ分散を決定します。

クローン フェーズ

クローン フェーズ実行中:

1. 各受信シャードは、ドナーのシャーディングされたコレクションと同じコレクションオプションを持つ、一時的な空のシャーディングされたコレクションを作成します。受信シャードは、インデックスフェーズまで _id 以外のインデックスを作成しません。

2. 各受信シャードは、ドナーシャードからコレクションデータをクローンし、クローンされたデータを一時コレクションに書き込み (write)ます。この一時コレクションには、新しいシャードキーの下で受信シャードが所有するすべてのドキュメントが含まれます。

インデックス フェーズ

インデックスフェーズでは、各受信者シャードは必要な新しいインデックスをビルドします。 これらには、シャーディングされたコレクションの既存のすべてのインデックスと、新しいシャードキーパターン と互換性のあるインデックス（シャーディングされたコレクションにインデックスがまだ存在しない場合）が含まれます。

適用フェーズとキャッチアップ フェーズ

適用フェーズとキャッチアップフェーズ中:

• 各受信者シャードは、受信者がデータをクローンした後に対応するドナー シャードに書込まれたoplogエントリの適用を開始します。

• リシャーディング操作を完了するための残り時間の推定値が 500 ミリ秒 未満の場合、ドナー シャードはソースコレクションへの書込みをブロックします。

コミット フェーズ

コミット フェーズ実行中:

• リシャーディング コーディネーターは、すべてのシャードが厳密な一貫性に達するまで待機し、 リシャーディング操作 をコミットします。

• リシャーディング コーディネーターは、各ドナー シャード プライマリと受信者シャード プライマリに対して、一時的にシャーディングされたコレクションの名前を変更するよう、個別に指示します。 一時的なコレクションは、新しいリシャーディングされたコレクションになります。

• 各ドナー シャードは、古いシャーディングされたコレクションを削除します。

コレクションの再シャーディング

次の例では、 sales.ordersコレクションを新しいシャードキー{ order_id: 1 }で再シャーディングします。

db.adminCommand({
  reshardCollection: "sales.orders",
  key: { order_id: 1 }
})

出力:

{
  ok: 1,
  '$clusterTime': {
    clusterTime: Timestamp(1, 1624887954),
    signature: {
      hash: Binary(Buffer.from("0000000000000000000000000000000000000000", "hex"), 0),
      keyId: 0
    }
  },
  operationTime: Timestamp(1, 1624887947)
}

新しいシャードへのデータの再配布

MongoDB 8.0 以降では、同じキーでコレクションを再シャーディングできます。これを使用して、新しいシャードにデータを再配布できます。

クラスターにシャードを追加した後、 reshardCollectionコマンドとforceRedistributionオプションを併用して、クラスター全体にデータを再分散します。

db.adminCommand({
    reshardCollection: "accounts.invoices",
    key: { store_id: "hashed" },
    forceRedistribution: true
})

異なるゾーンへのデータの再配布

MongoDB 8.0 以降では、 reshardCollection コマンドを使用して、シャードキー を変更せずにデータを新しいゾーンに移動できます。

次のコマンドは、同じシャードキーを使用して accounts.salesコレクションのデータを再配布し、ゾーン zone04 と zone05 に関連付けられているシャードにデータを移動します。

db.adminCommand({
    reshardCollection: "accounts.sales",
    key: { region_id: "hashed" },
    forceRedistribution: true,
    zones: [
        {
            zone: "zone04",
            min: { region_id: MinKey() },
            max: { region_id: 10 }
        },
        {
            zone: "zone05",
            min: { region_id: 10 },
            max: { region_id: MaxKey() }
        }
    ]
})