집계 파이프라인 단계

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

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

참고

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

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

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

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

일부 핵심 집계 파이프라인 단계는 다른 파이프라인 단계 내에 중첩된 경우에만 지원됩니다. 다음 표는 메인 파이프라인에서 사용되거나 지정된 집계 파이프라인 단계 내에 중첩된 경우 지원되는 집계 파이프라인 단계를 보여줍니다.

애그리게이션 단계	메인 파이프라인에서 지원됩니다.	`$tumblingWindow`, `$hoppingWindow`, `$sessionWindow`에서 지원됨	`$https` 및 `$externalFunction`에서 지원됩니다.
`$addFields`	√	√	√
`$project`	√	√	√
`$replaceRoot`	√	√	√
`$set`	√	√	√
`$redact`	√	√
`$match`	√	√
`$replaceWith`	√	√
`$unset`	√	√
`$unwind`	√	√
`$validate`	√	√
`$https`	√	√
`$externalFunction`	√	√
`$lookup` [1]	√	√
`$merge` [1]	√
`$tumblingWindow`	√
`$hoppingWindow`	√
`$sessionWindow`	√
$emit	√
`$group`		√
`$sort`		√
`$count`		√
`$limit`		√

[1]	(1, 2) 수정된 구문으로 지원됩니다.

돌아가기

$function

$source