sh.reshardCollection()

초기화 단계

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

인덱스 단계

인덱스 단계 중:

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

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

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

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

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

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

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

  참고

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

커밋 단계

• 리샤딩 프로세스가 커밋 단계에 도달한 후에는 sh.abortReshardCollection() 으로 프로세스를 종료할 수 없습니다.

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

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

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

  팁

  다음도 참조하세요.

  컬렉션 리샤딩

컬렉션 리샤딩

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

sh.reshardCollection( "sales.orders", { order_id: 1 } )

출력 예시:

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

구역이 있는 컬렉션 리샤딩

변화하는 요구 사항을 충족하거나 성능을 개선하기 위해 클러스터의 샤드 전체에 데이터 분산을 조정해야 하는 경우 구역으로 컬렉션을 리샤딩합니다.

다음 예시 에서 test.scores 컬렉션 은 shard0 및 shard1 에 있습니다. 현재 샤드 키 는 { _id: 1} 입니다.

sh.addShardToZone( "shard2", "NewZone" )
sh.addShardToZone( "shard3", "NewZone" )

sh.reshardCollection(
  "test.scores",
  { "studentId": 1, "testId": 1},
  { zones: [ {
    min: { "studentId": MinKey(), "testId": MinKey() },
    max: { "studentId": MaxKey(), "testId": MaxKey() },
    zone: "NewZone" }
    ]
} )

{
   ok: 1,
   '$clusterTime': {
   clusterTime: Timestamp( { t: 1699484530, i: 54 } ),
   signature: {
   hash: Binary.createFromBase64( "90ApBDrSSi4XnCpV3OWIH4OGO0Y=", 0 ),
   keyId: Long( "7296989036055363606" )
   } },
   operationTime: Timestamp( { t: 1699484530, i: 54 } )
}