$out (집계 단계)

정의

$out

집계 파이프라인에서 반환된 문서를 가져와서 지정된 컬렉션에 씁니다. 출력 데이터베이스를 지정할 수 있습니다.

$out 단계는 파이프라인의 마지막 단계여야 합니다. $out 연산자를 사용하면 집계 프레임워크에서 모든 크기의 결과 집합을 반환할 수 있습니다.

경고

$out 연산에서 지정한 컬렉션이 이미 존재하는 경우 $out 단계에서는 집계가 완료되면 기존 컬렉션을 새 결과 컬렉션으로 원자적으로 대체합니다. 자세한 내용은 기존 컬렉션 교체를 참조하세요.

구문

$out 단계에는 다음과 같은 구문이 있습니다.

• $out 출력 collection만 지정하는 문자열을 사용할 수 있습니다(즉, 동일한 데이터베이스의 collection으로 출력).

  { $out: "<output-collection>" } // Output collection is in the same database

• $out 출력 데이터베이스와 출력 컬렉션을 지정하기 위해 문서를 가져올 수 있습니다.

  { $out: { db: "<output-db>", coll: "<output-collection>" } }

• MongoDB 7.0.3 및 7.1 부터 $out는 문서를 시계열 컬렉션에 출력할 수 있습니다.

  { $out:
    { db: "<output-db>", coll: "<output-collection>",
      timeseries: {
        timeField: "<field-name>",
        metaField: "<field-name>",
        granularity:  "seconds" || "minutes" || "hours" ,
      }
    }
  }

  중요

  Time Series 세분성 변경

  Time Series 컬렉션을 만든 후 collMod 메서드를 사용하여 세분성을 수정할 수 있습니다. 그러나 각 버킷에 적용되는 기간을 늘릴 수만 있습니다. 줄일 수는 없습니다.

  필드	설명
  db	출력 데이터베이스의 이름입니다. 복제본 세트 또는 독립형의 경우 출력 데이터베이스가 존재하지 않으면 $out도 데이터베이스를 생성합니다. 샤딩된 클러스터의 경우 지정된 출력 데이터베이스가 이미 존재해야 합니다.
  coll	출력 collection 이름입니다.
  timeseries	Time Series 컬렉션에 쓸 때 사용할 구성을 지정하는 문서입니다. timeField는 필수 항목입니다. 다른 모든 필드는 선택 사항입니다.
  timeField	time series 컬렉션에 쓸 때 필요합니다. 각 time series 문서에서 날짜를 포함하는 필드의 이름입니다. time series 컬렉션의 문서에는 timeField 값으로 유효한 BSON 날짜가 있어야 합니다.
  metaField	선택 사항. 각 time series 문서에 메타데이터가 포함된 필드의 이름입니다. 지정된 필드의 메타데이터는 고유한 문서 시리즈에 레이블을 지정하는 데 사용되는 데이터여야 합니다. 메타데이터는 거의 변경되지 않아야 합니다. 지정된 필드의 이름은 _id이(가) 아니거나 timeseries.timeField 이름과 같지 않을 수 있습니다. 필드는 모든 데이터 유형이 가능합니다. metaField 필드는 선택 사항이지만 메타데이터를 사용하면 쿼리 최적화를 개선할 수 있습니다. 예를 들어 MongoDB는 새 컬렉션에 대해 metaField 및 timeField 필드에 복합 인덱스를 자동으로 생성합니다 . 이 필드에 값을 제공하지 않으면 데이터는 시간을 기준으로만 버킷됩니다.
  granularity	선택 사항입니다. bucketRoundingSeconds 및 bucketMaxSpanSeconds 을 설정한 경우에는 사용하지 마십시오. 가능한 값은 seconds (기본값), minutes 및 hours입니다. 연속적으로 들어오는 타임스탬프 사이의 시간과 가장 근접하게 일치하는 값으로 granularity 를 설정합니다. 이렇게 하면 MongoDB가 컬렉션에 데이터를 저장하는 방법을 최적화하여 성능이 향상됩니다. 세분 수준 및 버킷 간격에 대한 자세한 내용은 Time Series 데이터의 세부 수준 설정을 참조하세요.
  bucketMaxSpanSeconds	선택 사항입니다. bucketRoundingSeconds와 함께 granularity의 대안으로 사용합니다. 같은 버킷에 있는 타임스탬프 사이의 최대 시간을 설정합니다. 가능한 값은 1-31536000입니다. 버전 6.3에 추가.
  bucketRoundingSeconds	선택 사항. bucketMaxSpanSeconds와 함께 granularity의 대안으로 사용합니다. bucketMaxSpanSeconds와 같아야 합니다. 문서에 새 버킷이 필요한 경우 MongoDB는 문서의 타임스탬프 값을 이 간격으로 반올림하여 버킷의 최소 시간을 설정합니다. 버전 6.3에 추가.

동작

예시

db.getSiblingDB("test").books.insertMany([
   { "_id" : 8751, "title" : "The Banquet", "author" : "Dante", "copies" : 2 },
   { "_id" : 8752, "title" : "Divine Comedy", "author" : "Dante", "copies" : 1 },
   { "_id" : 8645, "title" : "Eclogues", "author" : "Dante", "copies" : 2 },
   { "_id" : 7000, "title" : "The Odyssey", "author" : "Homer", "copies" : 10 },
   { "_id" : 7020, "title" : "Iliad", "author" : "Homer", "copies" : 10 }
])

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

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

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

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

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

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

public class Movie
{
    public ObjectId Id { get; set; }
    public int Runtime { get; set; }
    
    public string Title { get; set; }
    public string Rated { get; set; }
    public List<string> Genres { get; set; }
    public string Plot { get; set; }
    
    public ImdbData Imdb { get; set; }
    public int Year { get; set; }
    public int Index { get; set; }
    
    public string[] Comments { get; set; }
   
    [BsonElement("lastupdated")]
    public DateTime LastUpdated { get; set; }
}

var camelCaseConvention = new ConventionPack { new CamelCaseElementNameConvention() };
ConventionRegistry.Register("CamelCase", camelCaseConvention, type => true);

var movieCollection = client
    .GetDatabase("sample_mflix")
    .GetCollection<Movie>("movies");
var pipeline = new EmptyPipelineDefinition<Movie>()
    .Out(movieCollection);

const pipeline = [{ $out: { db: "sample_mflix", coll: "movies" } }];
const cursor = collection.aggregate(pipeline);
return cursor;