Estágios do pipeline de agregação

O Atlas Stream Processing estende opipeline de agregação do com estágios para processar fluxos de dados contínuos. Esses estágios se combinam com os estágios de agregação existentes incorporados ao processo mongod padrão, permitindo que você execute muitas das mesmas operações em dados contínuos que você pode executar em dados em repouso. Uma definição de pipeline do Atlas Stream Processing não pode exceder 16 MB.

A tabela seguinte lista os estágios do aggregation pipeline exclusivos para o Atlas Stream Processing e aqueles que existem de forma modificada no Atlas Stream Processing.

Observação

Para obter detalhes sobre um operador específico, incluindo sintaxe e exemplos, clique no link para a página de referência do operador.

Estágio do pipeline de agregação	Propósito
$source	Especifica um conjunto de dados de streaming para consumir mensagens.
$validar	Valida os documentos de um fluxo em relação a um esquema definido pelo usuário.
$HTTPS	Oferece suporte a chamadas semelhantes a `curl`para pontos de extremidade arbitrários da REST API dentro do seu processador de fluxo.
$lookup	Realiza uma união externa esquerda em uma collection especificada para filtrar documentos da collection "unida" para processamento. Esta versão do estágio `$lookup` existente requer que você especifique uma coleção do Atlas no registro de conexão como o valor para o campo `from`.
$hoppingWindow	Atribui documento de um stream a Windows com durações definidas pelo usuário e intervalos entre os horários de início.
$tumblingWindow	Atribui documento de um fluxo a Windows contínuas e não sobrepostas com durações definidas pelo usuário.
$emit	Especifica um fluxo ou coleção de séries temporais no registro de conexão para emitir mensagens.
$merge	Uma versão do estágio `$merge` existente (Atlas Data Federation) em que o valor do campo `connectionName` deve ser sempre o nome de uma coleção remota no Registro de Conexão.
$sessionWindow	Executa um pipeline em cada sessão de atividade em um fluxo de entrada. Cada documento é atribuído a uma janela de sessão com base em sua partição e carimbo de data e hora.

Estágios de pipeline de agregação suportados

O Atlas Stream Processing fornece várias extensões para a sintaxe principal do MongoDB Aggregation Pipeline . Para saber mais sobre essas extensões, consulte Estágios de pipeline de agregação suportados.

Certas fases do pipeline de agregação são suportadas apenas quando aninhadas dentro de outras fases do pipeline. A tabela a seguir mostra quais fases do pipeline de agregação são suportadas para uso no pipeline principal ou quando aninhadas nas fases do pipeline de agregação especificadas.

Estágio de agregação	Suportadas no pipeline principal	Compatível com `$tumblingWindow`, `$hoppingWindow` e `$sessionWindow`	Suportadas em `$https` e `$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) Suportadas com sintaxe modificada.

Voltar

$function

$source