reshardCollection

초기화 단계

초기화 단계에서 리샤딩 코디네이터는 샤딩된 컬렉션에 대한 새 데이터 분포를 결정합니다.

인덱스 단계

인덱스 단계 중:

• 각 샤드 수신자는 기존 샤드 컬렉션과 동일한 컬렉션 옵션을 사용하여 빈 샤드 컬렉션을 새로 생성합니다. 이 새로운 샤드 컬렉션은 수신자 샤드가 새 데이터를 쓰는 위치의 대상입니다.

• 각 샤드 수신자는 필요한 새 인덱스를 빌드합니다. 여기에는 샤드 컬렉션의 모든 기존 인덱스와 새 샤드 키 패턴과 호환되는 인덱스(해당 인덱스가 샤드 컬렉션에 아직 존재하지 않는 경우)가 포함됩니다.

복제, 적용 및 따라잡기 단계

복제, 적용 및 따라잡기 단계에서 다음을 수행합니다.

• 각 샤드 수신자는 새 샤드 키 하에 소유하게 될 문서의 초기 사본을 복제합니다.

• 각 샤드 수신자는 수신자가 데이터를 복제한 후에 발생한 작업의 oplog 항목을 적용하기 시작합니다.

• 리샤딩 작업을 완료하는 데 남은 시간의 예상이 2초 미만인 경우 리샤딩 조정자는 컬렉션에 대한 쓰기를 차단합니다.

  참고

  원하는 경우 commitReshardCollection 명령을 실행하여 리샤딩 작업을 수동으로 강제로 완료할 수 있습니다. 이는 리샤딩 작업을 완료하는 데 걸리는 현재 예상 시간이 컬렉션에서 쓰기를 차단하기에 적합한 기간인 경우에 유용합니다. commitReshardCollection 명령은 쓰기를 조기에 차단하고 리샤딩 작업을 강제로 완료합니다. 쓰기가 차단되는 기간 동안 애플리케이션의 지연 시간이 증가합니다.

커밋 단계

• 리샤딩 프로세스가 커밋 단계에 도달하면 더 이상 abortReshardCollection 으로 중단될 수 없습니다.

• 모든 샤드가 엄격한 일관성에 도달하면 리샤딩 조정자가 리샤딩 작업을 커밋하고 새 라우팅 테이블을 설치합니다.

• 리샤딩 조정자는 각 기증자와 수신자 샤드 프라이머리에 독립적으로 임시 샤드 컬렉션의 이름을 바꾸도록 지시합니다. 임시 컬렉션은 새로운 리샤딩 컬렉션이 됩니다.

• 각 기증자 샤드는 이전 샤드 컬렉션을 삭제합니다.

  팁

  다음도 참조하세요.

  컬렉션 리샤딩

컬렉션 리샤딩

다음 예시에서는 새 샤드 키 { order_id: 1 } 을(를) 사용하여 sales.orders 컬렉션을 리샤딩합니다.

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 7.2부터는 동일한 키의 collection을 리샤딩할 수 있으며, 이를 사용하여 새 샤드에 데이터를 재배분할 수 있습니다.

cluster에 샤드를 추가한 후 reshardCollection 명령과 forceRedistribution 옵션을 사용하여 cluster 전체에 데이터를 재배포합니다.

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

서로 다른 구역에 데이터 재배포

MongoDB 7.2부터 reshardCollection 명령을 사용하여 샤드 키를 변경하지 않고도 데이터를 새 구역으로 이동할 수 있습니다.

다음 명령은 accounts.sales 동일한 샤드 키를 사용하여 collection의 데이터를 재배포하여 zone01 zones zone02 zone03 및 에서 및 로 데이터를 zone04 이동합니다.

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() }
        }
    ]
})