커서를 사용하여 데이터 액세스

개요

이 가이드에서는 Rust 드라이버를 사용하여 커서 를 사용하여 읽기 작업 또는 애그리게이션에서 반환된 데이터에 액세스하는 방법을 배울 수 있습니다. 커서는 주어진 시간에 문서의 하위 집합만 메모리에 유지하면서 문서를 반복할 수 있는 메커니즘입니다.

드라이버는 커서에서 문서를 검색하는 Cursor 유형을 제공합니다. 예를 들어, 여러 문서를 반환할 수 있는 찾기 작업을 실행하면 드라이버는 일치하는 문서에 액세스할 수 있는 Cursor 인스턴스를 반환합니다.

읽기 작업 또는 애그리게이션을 실행한 후 반환된 Cursor 인스턴스에는 작업의 첫 번째 결과 배치가 포함됩니다. 커서를 반복할수록 서버는 더 많은 개별 결과를 반환합니다. 결과 배치의 끝에 도달한 후 일치하는 문서가 더 있는 경우 Cursor 인스턴스는 모든 결과가 반환될 때까지 다음 문서 배치를 가져옵니다.

이 가이드에는 다음 섹션이 포함되어 있습니다.

• 예제용 샘플 데이터는 커서 예제에서 사용되는 샘플 데이터를 제공합니다.

• 문서 개별 조회 에서는 반복 또는 스트림을 사용하여 한 번에 하나씩 결과에 액세스하는 방법을 설명합니다.

• 문서를 배열로 조회하기에서는 반환된 커서 결과를 수집하여 모든 결과에 단일 배열 로 액세스 하는 방법을 설명합니다.

• 원시 문서 배치 조회 에서는 BSON 데이터에 직접 액세스 하고 제로 카피 문서 처리 위해 원시 배치 커서 API 사용하는 방법을 설명합니다.

• 커서 동작 지정 에서는 메서드가 반환하는 커서 를 구성하는 방법을 설명합니다.

• 추가 정보에서 이 가이드에 언급된 유형 및 메소드에 대한 리소스 및 API 문서 링크를 찾을 수 있습니다.

예시용 샘플 데이터

이 가이드의 예제에서는 구조체에 저장된 다음 데이터를 사용합니다.

let docs = vec! [
    Fruit { 
        name: "strawberry".to_string(), 
        color: "red".to_string() 
    },
    Fruit { 
        name: "banana".to_string(), 
        color: "yellow".to_string() 
    },
    Fruit { 
        name: "pomegranate".to_string(), 
        color: "red".to_string() 
    },
    Fruit { 
        name: "pineapple".to_string(), 
        color: "yellow".to_string() 
    }
];

문서 개별 조회

드라이버는 Cursor 인스턴스에서 반환한 문서를 반복할 수 있도록 다음과 같은 액세스 패턴을 제공합니다.

• 내장 패턴: 커서를 앞으로 이동한 다음 현재 문서를 검색하고 역직렬화합니다.

• 스트림 구현 패턴: 커서 반복하고 에서 제공하는 메서드를 호출하여 Stream 단일 또는 여러 문서를 프로세스 .

다음 섹션에서는 이러한 액세스 패턴과 해당 방법에 대해 자세히 설명합니다.

let mut cursor = my_coll.find(doc! { "color": "red" }).await?;
while cursor.advance().await? {
    println!("{:?}", cursor.deserialize_current()?);
}

Fruit { name: "strawberry", color: "red" }
Fruit { name: "pomegranate", color: "red" }

let mut cursor = my_coll.find(doc! { "color": "red" }).await?;
println!("Output from next() iteration:");
while let Some(doc) = cursor.next().await {
    println!("{:?}", doc?);
}
println!();
let mut cursor = my_coll.find(doc! { "color": "yellow" }).await?;
println!("Output from try_next() iteration:");
while let Some(doc) = cursor.try_next().await? {
    println!("{:?}", doc);
}

Output from next() iteration:
Fruit { name: "strawberry", color: "red" }
Fruit { name: "pomegranate", color: "red" }
Output from try_next() iteration:
Fruit { name: "banana", color: "yellow" }
Fruit { name: "pineapple", color: "yellow" }

문서를 배열로 조회

Cursor 유형은 Stream 특성을 구현하므로 커서에서 결과를 배열로 수집할 수 있습니다.

다음 메서드를 사용하여 문서를 배열로 조회할 수 있습니다.

• collect(): 커서의 결과를 Vec<Result<T>> 유형으로 수집합니다.

• try_collect(): 커서의 결과를 Result<Vec<T>> 유형으로 수집합니다.

let cursor = my_coll.find(doc! { "color": "red" }).await?;
println!("Output from collect():");
let v: Vec<Result<Fruit>> = cursor.collect().await;
println!("{:?}", v);
println!();
let cursor = my_coll.find(doc! { "color": "yellow" }).await?;
println!("Output from try_collect():");
let v: Vec<Fruit> = cursor.try_collect().await?;
println!("{:?}", v);

Output from collect():
[Ok(Fruit { name: "strawberry", color: "red" }), Ok(Fruit { name: "pomegranate", color: "red" })]
Output from try_collect():
[Fruit { name: "banana", color: "yellow" }, Fruit { name: "pineapple", color: "yellow" }]

원시 배치 커서 사용

find() 와 같은 커서 반환 작업에서 batch() 메서드를 호출하여 RawBatchCursor를 반환할 수 있습니다. 이를 통해 개별 역직렬화된 값 대신 서버 에서 반환된 원시 BSON 문서 배치를 반복할 수 있습니다. 이 모듈은 서버 응답 배치에 직접 액세스 해야 할 때 문서를 고성능으로 프로세스 방법을 제공합니다. 처리량 높고 성능에 민감한 커서 애플리케이션에는 원시 배치 모드 사용하세요.

let mut cursor = my_coll.find(doc! { "color": "red" }).batch().await?;
while let Some(batch) = cursor.next().await {
    let batch = batch?;
    let doc_slices = batch.doc_slices()?;
    let count = doc_slices.into_iter().count();
    println!("Processing batch with {} documents", count);
    for doc_result in batch.doc_slices()? {
        let doc = doc_result?;
        if let mongodb::bson::RawBsonRef::Document(raw_doc) = doc {
            println!("Raw document size: {} bytes", raw_doc.as_bytes().len());
        }
    }
}

Processing batch with 4 documents
Raw document size: 58 bytes
Raw document size: 59 bytes
Raw document size: 58 bytes
Raw document size: 59 bytes

커서 동작 지정

작업에서 반환하는 커서 를 수정하려면 Cursor 인스턴스 를 반환하는 메서드에 옵션 빌더 메서드를 연결합니다. 예를 예시 커서 관련 옵션 빌더 메서드를 find() 메서드에 연결할 수 있습니다.

다음 표에서는 해당 빌더 메서드를 호출하여 설정하다 수 있는 커서 관련 옵션에 대해 설명합니다.

다음 코드는 옵션 빌더 메서드를 find() 메서드에 연결하여 커서 관련 설정을 지정하는 방법을 보여줍니다.

let mut cursor = my_coll.find(doc! { "color": "red" })
    .batch_size(5)
    .cursor_type(CursorType::Tailable)
    .no_cursor_timeout(true)
    .await?;

추가 정보

이 가이드의 작업에 대해 자세히 알아보려면 다음 문서를 참조하세요.

• 문서 찾기 가이드

• 쿼리 가이드 지정

Rust 유형과 BSON 간의 변환에 대해 자세히 알아보려면 데이터 모델링 및 직렬화 가이드를 참조하세요.