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

이 페이지의 내용

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

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

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

경고

stream_meta 필드는 $project 또는 $unset 단계에서만 제거할 수 있습니다. 이 필드는 아래에 정의된 명시적인 호출 두 가지 중 하나를 통해서만 제거할 수 있습니다.

{$project : { _stream_meta : 0 }}

{$unset : ["_stream_meta"]}

참고

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

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

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

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

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

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

돌아가기

$convert

$source