Etapas de la pipeline de agregación

Atlas Stream Processing extiende la pipeline 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 mongod predeterminado, lo que le permite realizar muchas de las mismas operaciones en datos continuos que puede realizar en datos en reposo. Una definición de pipeline de Atlas Stream Processing no puede exceder los 16 MB.

La siguiente tabla enumera las etapas del pipeline de agregación que son exclusivas de Atlas Stream Processing y aquellas que existen en forma modificada en Atlas Stream Processing.

Nota

Para más detalles sobre un operador específico, incluyendo sintaxis y ejemplos, haz clic en el enlace a la página de referencia del operador.

Etapa de la canalización de agregación	Propósito
$source	Especifica una fuente de datos de transmisión desde la que se consumirán mensajes.
$validate	Valida los documentos de un flujo con un esquema definido por el usuario.
$https	Admite llamadas similares a `curl`a puntos finales arbitrarios de la API REST dentro de su procesador de flujo.
$lookup	Realiza una combinación externa izquierda en una colección especificada para incluir documentos de la colección «combinada» para su procesamiento. Esta versión de la etapa existente `$lookup` requiere que especifiques una colección de Atlas en el Registro de Conexión como el valor para el campo `from`.
$hoppingWindow	Asigna documentos de un flujo a ventanas con duraciones definidas por el usuario e intervalos entre los tiempos de inicio.
$tumblingWindow	Asigna documentos de un flujo a ventanas continuas, sin solapamiento, con duraciones definidas por el usuario.
$sessionWindow	Ejecuta una pipeline en cada "sesión" de actividad en un flujo de entrada. A cada documento se le asigna una ventana de sesión según su partición y marca de tiempo.
$setStreamMeta	Establece un campo de metadatos en los documentos de una secuencia de entrada. Este campo de metadatos puede utilizarse para realizar operaciones dinámicas, como el enrutamiento de sumideros, en documentos sin cambiar el contenido de su cuerpo.
$emit	Especifica una secuencia o colección de series de tiempo en el registro de conexiones para emitir mensajes.
$merge	Una versión de la etapa `$merge` (Atlas Data Federation) existente, donde el valor del campo `connectionName` debe ser siempre el nombre de una colección remota en el Registro de conexiones.

Etapas del pipeline 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 centrales del pipeline de agregación solo se admiten cuando están anidadas dentro de otras etapas del pipeline. La siguiente tabla muestra qué etapas del pipeline de agregación son compatibles para su uso dentro del pipeline principal o cuando están anidadas dentro de las etapas del pipeline de agregación especificadas.

etapa de agregación	Compatible con Main Pipeline	Compatible con `$tumblingWindow`, `$hoppingWindow` y `$sessionWindow`	Compatibilidad en `$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

$source