Etapas de la pipeline de agregación

Atlas Stream Processing amplía la Canal de agregación con etapas para procesar flujos de datos continuos. Estas etapas se combinan con las etapas de agregación existentes integradas en el sistema predeterminado.mongod Proceso que permite realizar muchas de las mismas operaciones con datos continuos que con datos en reposo. Una definición de canalización de Atlas Stream Processing no puede superar los 16 MB.

En la siguiente tabla se enumeran las etapas de la canalización de agregación exclusivas de Atlas Stream Processing y aquellas que existen en forma modificada en Atlas Stream Processing.

Nota

Para obtener detalles sobre un operador específico, incluida la sintaxis y ejemplos, haga clic en el enlace a la página de referencia del operador.

Etapa de la canalización de agregación	Propósito
$fuente	Especifica una fuente de datos de transmisión desde la que se consumirán mensajes.
$validar	Valida los documentos de una secuencia contra un esquema definido por el usuario.
$https	Admite llamadas de tipo `curl`a puntos finales de API REST arbitrarios dentro de su procesador de flujo.
$lookup	Realiza una unión externa izquierda a una colección especificada para filtrar documentos de la colección "unida" para su procesamiento. Esta versión de la `$lookup` etapa existente requiere que especifique una colección Atlas en el Registro de conexión como valor para el `from` campo.
$hoppingWindow	Asigna documentos de una secuencia a ventanas con duraciones definidas por el usuario e intervalos entre horas de inicio.
$tumblingWindow	Asigna documentos de un flujo a ventanas continuas, sin solapamiento, con duraciones definidas por el usuario.
$sessionWindow	Ejecuta una canalización en cada sesión de actividad en un flujo de entrada. Cada documento se asigna a una ventana de sesión según su partición y marca de tiempo.
$setStreamMeta	Establece un campo de metadatos en los documentos de un flujo de entrada. Este campo de metadatos permite realizar operaciones dinámicas, como el enrutamiento de destino, en los documentos sin modificar su contenido.
$emit	Especifica una colección de secuencias o series de tiempo en el registro de conexión a la que se emitirán mensajes.
$merge	Una versión de la etapa `$merge` existente (Atlas Data Federation) donde el valor del `connectionName` campo siempre debe ser el nombre de una colección remota en el Registro de conexión.

Etapas de canalización de agregación admitidas

Atlas Stream Processing ofrece varias extensiones a la sintaxis principal de la canalización de agregación de MongoDB. Para obtener más información sobre estas extensiones, consulte Etapas de la canalización de agregación compatibles.

Ciertas etapas principales de la canalización de agregación solo son compatibles cuando están anidadas dentro de otras etapas de la canalización. La siguiente tabla muestra qué etapas de la canalización de agregación son compatibles con la canalización principal o cuando están anidadas dentro de las etapas de la canalización de agregación especificadas.

Etapa de agregación	Compatible con Main Pipeline	Compatible con,`$tumblingWindow` `$hoppingWindow`y `$sessionWindow`	Compatible con `$https` y `$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) Compatible con sintaxis modificada.

Volver

$function

$fuente