$out (aggregation)

와(과) 비교하기 $merge

MongoDB는 집계 파이프라인의 결과를 컬렉션에 쓰기 위한 두 단계인 $merge 및 $out을 제공합니다. 다음은 두 단계의 기능을 요약한 것입니다.

$out 읽기 작업이 세컨더리 복제본 세트 멤버에서 실행

MongoDB 5.0부터 클러스터의 모든 노드에 featureCompatibilityVersion 이 5.0 이상으로 설정되어 있고 읽기 설정이 보조로 설정된 경우 복제본 세트 세컨더리 노드에서 $out을 실행할 수 있습니다.

$out 문의 읽기 연산은 세컨더리 노드에서 발생하는 반면 쓰기 연산은 프라이머리 노드에서만 발생합니다.

모든 드라이버 버전이 복제본 세트 세컨더리 노드에 대한 $out 작업 대상 지정을 지원하는 것은 아닙니다. 드라이버 설명서를 확인하여 드라이버가 세컨더리에서 실행 중인 $out 에 대한 지원을 언제 추가했는지 확인합니다.

새 collection 만들기

$out 연산은 아직 컬렉션이 없는 경우 새 컬렉션을 만듭니다.

애그리게이션이 완료될 때까지 collection은 표시되지 않습니다. 애그리게이션이 실패하면 MongoDB는 collection을 생성하지 않습니다.

기존 collection 교체

$out 연산에서 지정한 컬렉션이 이미 존재하는 경우, 집계가 완료되면 $out 단계에서 기존 컬렉션을 새 결과 컬렉션으로 원자적으로 대체합니다. 구체적으로는 다음과 같은 $out 연산입니다.

1. 임시 컬렉션을 생성합니다.

2. 기존 collection의 인덱스를 임시 collection으로 복사합니다.

3. 임시 컬렉션에 문서를 삽입합니다.

4. dropTarget: true와 함께 renameCollection 명령을 호출해 임시 컬렉션의 이름을 대상 컬렉션으로 지정합니다.

지정된 컬렉션이 존재하고 $out 연산이 timeseries 옵션을 지정하는 경우 다음 제한 사항이 적용됩니다.

1. 기존 컬렉션은 Time Series 컬렉션이어야 합니다.

2. 기존 컬렉션은 뷰가 아니어야 합니다.

3. $out 단계에 포함된 timeseries 옵션은 기존 컬렉션의 옵션과 정확히 일치해야 합니다.

$out 연산은 이전 컬렉션에 있던 인덱스를 변경하지 않습니다. 집계가 실패하면 $out 연산은 기존 컬렉션에 변경 사항을 만들지 않습니다.

인덱스 제약

파이프라인에서 생성한 문서가 원래 출력 컬렉션의 _id 필드에 있는 고유 인덱스를 비롯해 그 어떤 고유 인덱스라도 위반할 경우 파이프라인이 완료되지 않습니다.

$out 연산으로 Atlas Search 인덱스가 있는 컬렉션을 수정하는 경우 검색 인덱스를 삭제하고 다시 만들어야 합니다. 대신 $merge 사용을 고려할 수 있습니다.

majority readConcern

단계를 포함하는 애그리게이션에 $out 대해 "majority" 읽기 고려 수준 을 지정할 수 있습니다.

다음과의 상호 작용 mongodump

mongodump --oplog 클라이언트가 덤프 프로세스 중에 가 포함된 집계 파이프라인을 실행하면 로 $out 시작된 가 실패합니다. 자세한 내용은 를 mongodump --oplog 참조하세요.

제한 사항

동일한 데이터베이스로 출력하기

다음 애그리게이션 작업은 test 데이터베이스의 books collection에 있는 데이터를 피벗하여 제목을 저자별로 그룹화한 다음 그 결과를 test 데이터베이스의 authors collection에 씁니다.

db.getSiblingDB("test").books.aggregate( [
    { $group : { _id : "$author", books: { $push: "$title" } } },
    { $out : "authors" }
] )

첫 번째 단계 ($group):

$group 단계는 authors를 기준으로 그룹화하고 $push를 사용하여 제목을 books 배열 필드에 추가합니다.

{ "_id" : "Dante", "books" : [ "The Banquet", "Divine Comedy", "Eclogues" ] }
{ "_id" : "Homer", "books" : [ "The Odyssey", "Iliad" ] }

두 번째 단계 ($out):

$out 단계에서는 test 데이터베이스의 authors 컬렉션에 문서를 출력합니다.

출력 collection의 문서를 보려면 다음 작업을 실행합니다.

db.getSiblingDB("test").authors.find()

컬렉션에는 다음 문서가 포함되어 있습니다.

{ "_id" : "Homer", "books" : [ "The Odyssey", "Iliad" ] }
{ "_id" : "Dante", "books" : [ "The Banquet", "Divine Comedy", "Eclogues" ] }

다른 데이터베이스로 출력

$out 애그리게이션이 실행되는 위치와 다른 데이터베이스의 collection으로 출력할 수 있습니다.

다음 애그리게이션 작업은 books 컬렉션의 데이터를 피벗하여 제목이 작성자별로 그룹화한 다음 reporting 데이터베이스의 authors 컬렉션에 결과를 씁니다.

db.getSiblingDB("test").books.aggregate( [
    { $group : { _id : "$author", books: { $push: "$title" } } },
    { $out : { db: "reporting", coll: "authors" } }
] )

첫 번째 단계 ($group):

$group 단계는 authors를 기준으로 그룹화하고 $push를 사용하여 제목을 books 배열 필드에 추가합니다.

{ "_id" : "Dante", "books" : [ "The Banquet", "Divine Comedy", "Eclogues" ] }
{ "_id" : "Homer", "books" : [ "The Odyssey", "Iliad" ] }

두 번째 단계 ($out):

$out 단계에서는 reporting 데이터베이스의 authors 컬렉션에 문서를 출력합니다.

출력 collection의 문서를 보려면 다음 작업을 실행합니다.

db.getSiblingDB("reporting").authors.find()

컬렉션에는 다음 문서가 포함되어 있습니다.

{ "_id" : "Homer", "books" : [ "The Odyssey", "Iliad" ] }
{ "_id" : "Dante", "books" : [ "The Banquet", "Divine Comedy", "Eclogues" ] }