지원되는 집계 파이프라인 단계

이 페이지의 내용

지원되는 집계 파이프라인 단계

Atlas Stream Processing은 연속 데이터 스트림을 처리하는 단계를 통해 집계 파이프라인 을 확장합니다. 이러한 단계는 기본 mongod 프로세스에 내장된 기존 애그리게이션 단계와 결합되어, 미사용 데이터에서 수행할 수 있는 것과 동일한 여러 작업을 연속 데이터에서 수행할 수 있습니다. Atlas Stream Processing 파이프라인 정의는 16 MB를 초과할 수 없습니다.

다음 표에는 Atlas Stream Processing에 고유한 집계 파이프라인 단계와 Atlas Stream Processing에서 수정된 형태로 존재하는 단계가 나열되어 있습니다.

참고

구문 및 예제를 포함하여 특정 연산자에 대한 자세한 내용을 보려면 연산자의 참조 페이지에 대한 링크를 클릭하십시오.

aggregation pipeline 단계	목적
`$source`	메시지를 사용할 스트리밍 데이터 소스를 지정합니다.
`$validate`	사용자 정의 스키마에 대해 스트림 문서의 유효성을 검사합니다.
$lookup	지정된 collection에 왼쪽 외부 조인을 수행하여 "조인된" collection의 문서를 필터링하여 처리합니다. 기존 `$lookup` 단계의 이 버전에서는 연결 레지스트리 에서 `from` 필드의 값으로 Atlas 컬렉션을 지정해야 합니다.
`$hoppingWindow`	사용자 정의 기간과 시작 시간 간격을 사용하여 스트림의 문서를 Windows 에 할당합니다.
`$tumblingWindow`	스트림의 문서를 사용자 정의 기간이 있는 겹치지 않는 연속 Windows 에 할당합니다.
$emit	메시지를 내보낼 연결 레지스트리의 스트림 또는 Time Series 컬렉션을 지정합니다.
$merge	필드의 값이 항상 연결 레지스트리 에 있는 원격 collection의 이름이어야 하는 기존 `$merge`단계 버전입니다.`connectionName`

스트리밍 데이터 파이프라인의 모든 mongod 프로세스에서 지원하는 다음 단계를 사용할 수도 있습니다.

aggregation pipeline 단계	사용 조건
`$addFields`	어디서나
`$match`	어디서나
`$project`	어디서나
`$redact`	어디서나
`$replaceRoot`	어디서나
`$replaceWith`	어디서나
`$set`	어디서나
`$unset`	어디서나
`$unwind`	어디서나
`$group`	`$hoppingWindow` 또는 `$tumblingWindow` 단계 내에서만 가능합니다.
`$sort`	`$hoppingWindow` 또는 `$tumblingWindow` 단계 내에서만 가능합니다.
`$limit`	`$hoppingWindow` 또는 `$tumblingWindow` 단계 내에서만 가능합니다.
`$count`	`$hoppingWindow` 또는 `$tumblingWindow` 단계 내에서만 가능합니다.

지원되는 집계 파이프라인 단계

Atlas Stream Processing은 핵심 MongoDB 집계 파이프라인 구문에 대한 여러 가지 확장을 제공합니다. 이러한 확장에 대해 자세히 알아보려면 지원되는 집계 파이프라인 단계를 참조하세요.

특정 핵심 집계 파이프라인 단계는 다음 표에 명시된 대로 지원이 제한되거나 지원되지 않습니다. 표에 없는 단계는 Atlas Stream Processing에서 지원하는 것입니다.

애그리게이션 단계	지원 상태
`$group`	`$tumblingWindow` 또는 `$hoppingWindow` 에서만 지원됩니다.
`$sort`	`$tumblingWindow` 또는 `$hoppingWindow` 에서만 지원됩니다.
`$limit`	`$tumblingWindow` 또는 `$hoppingWindow` 에서만 지원됩니다.
`$count`	`$tumblingWindow` 또는 `$hoppingWindow` 에서만 지원됩니다.
`$merge`	수정된 구문으로 지원됩니다. 자세한 내용은 `$merge` 를 참조하세요.
`$lookup`	수정된 구문으로 지원됩니다. 자세한 내용은 `$lookup` 를 참조하세요.

← 스트림 프로세서 관리

$source →