MongoDB 서버 선택 사용자 지정

개요

모든 MongoDB 드라이버는 읽거나 쓰기 (write) 서버 선택할 때 정의된 알고리즘 따릅니다. MongoDB Rust 드라이버 하면 이 알고리즘 사용자 지정하여 애플리케이션 에 가장 적합한 서버 선택할 수 있습니다.

다음과 같은 방법으로 서버 선택에 영향을 줄 수 있습니다.

• 읽기 설정 (read preference) 사용하여 프라이머리, 세컨더리 또는 태그를 지정하다 세트 및 최대 비활성 상태로 가장 가까운 서버와 같은 표준화된 방식으로 적합한 서버를 설명합니다.

• SelectionCriteria::Predicate 를 통해 사용자 지정 조건자를 제공하여 적절한 서버를 필터링할 때 자체 로직을 적용 .

사용자 지정 선택 알고리즘

Rust 운전자 사용자 지정 선택 기준을 사용하여 작업을 실행할 때 MongoDB deployment 선택하기 위해 다음 단계를 순서대로 수행합니다.

1. 적격 서버 선택: 알려진 서버 SelectionCriteria 목록에서 운전자 읽기 설정 (read preference) 일치하는 서버 또는 사용자 지정 조건자가 을 반환하는 활성 와 일치하는 true 서버를 선택합니다.

2. 지연 시간 창 적용 : 운전자 local_threshold 적격 서버 목록에 설정을 적용하여 평균 왕복 시간이 가장 빠른 적격 서버 의 구성된 창 벗어나는 서버 필터링합니다.

3. 무작위 선택: 운전자 지연 시간 창 에 남아 있는 서버 중에서 무작위로 서버 선택하고 이 서버 대해 작업을 실행합니다.

Rust 운전자 쓰기 (write) 작업을 실행할 때 활성 읽기 설정 (read preference) 일치하는 서버뿐만 아니라 쓰기 가능한 모든 서버를 선택하는 것으로 시작합니다. 나머지 단계는 동일합니다.

기본값 서버 선택 알고리즘 에 대해 자세히 학습 MongoDB Server 매뉴얼에서 서버 선택 알고리즘을 참조하세요.

선택 기준 및 조건자

Rust 운전자 다음 예시 와 같이 SelectionCriteria 열거형 사용하여 서버 선택 규칙을 나타냅니다.

pub enum SelectionCriteria {
    ReadPreference(ReadPreference),
    Predicate(Predicate),
}

특정 작업에 대해 SelectionCriteria::ReadPreference 또는 SelectionCriteria::Predicate 중 하나를 사용하고 둘 다 사용하지는 않습니다.

• ReadPreference: 표준 MongoDB 읽기 설정 (read preference) 규칙에 따라 서버 유형, 태그를 지정하다 세트, 최대 비활성 상태를 기준으로 적합한 서버를 설명합니다.

• Predicate: 호스트 이름 패턴 또는 기타 사용자 지정 기준에 따라 서버를 선호하는 경우와 같이 ReadPreference 에서 표현할 수 없는 경우에 대한 사용자 지정 로직을 제공할 수 있습니다.

조건자는 ServerInfo 참조를 허용하고 서버 적합성을 나타내는 true을 반환하는 모든 클로저입니다. 운전자 이를 다음 코드에 표시된 Predicate 유형 별칭으로 정의합니다.

pub type Predicate = Arc<dyn Send + Sync + Fn(&ServerInfo) -> bool>;

술어가 해당 서버의 ServerInfo 값에 대해 true 을 반환하면 서버 적합한 것으로 간주됩니다. ServerInfo 유형은 주소, 유형 및 기타 모니터링 메타데이터 와 같은 서버 에 대한 정보를 노출합니다.

예제: 조건자를 사용하여 localhost에서 서버 선택

여러 개의 mongos 서버가 있는 샤딩된 클러스터 사용하는 경우 localhost에서 배포를 실행 좋습니다. 이러한 배포에 대한 작업은 지연 시간 짧고 처리량 높습니다. 이 예시 localhost에서 실행 서버만 고려하도록 서버 선택 알고리즘 사용자 지정하는 방법을 보여 줍니다.

let prefer_localhost = Arc::new(|server_info: &ServerInfo| {
    matches!(
        server_info.address(),
        ServerAddress::Tcp { host, .. } if host == "localhost"
    )
});

let prefer_localhost = Arc::new(|server_info: &ServerInfo| {
    matches!(
        server_info.address(),
        ServerAddress::Tcp { host, .. } if host == "localhost"
    )
});
let options = ClientOptions::builder()
    .hosts(vec![ServerAddress::Tcp {
        host: "<hostname>".to_string(),
        port: Some(27017),
    }])
    .selection_criteria(SelectionCriteria::Predicate(prefer_localhost))
    .build();
let client = Client::with_options(options)?;

let mut options = ClientOptions::parse(
    "mongodb://<db_username>:<db_password>@<hostname>:<port>",
)
.await?;
let prefer_localhost = Arc::new(|server_info: &ServerInfo| {
    matches!(
        server_info.address(),
        ServerAddress::Tcp { host, .. } if host == "localhost"
    )
});
options.selection_criteria = Some(
    SelectionCriteria::Predicate(prefer_localhost),
);
let client = Client::with_options(options)?;

API 문서

Rust 드라이버의 서버 선택 알고리즘 사용자 지정에 대한 자세한 내용은 다음 API 문서를 참조하세요.

• 선택 기준

• ServerInfo

• 몽고클라이언트