Estágios de pipeline de agregação suportados

Nesta página

Estágios de pipeline de agregação suportados

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.

Aviso

O campo stream_meta só pode ser removido com um estágio $project ou $unset. Você só pode remover esse campo com uma das duas chamadas explícitas, conforme definido a seguir:

{$project : { _stream_meta : 0 }}

{$unset : ["_stream_meta"]}

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.
`$validate`	Valida os documentos de um fluxo em relação a um esquema definido pelo usuário.
$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 em que o valor do campo `connectionName` deve ser sempre o nome de uma collection remota no Registro de conexão.

Você também pode utilizar os seguintes estágios suportados por todos os processos do mongod em suas pipelines de dados de streaming:

Estágio do pipeline de agregação	Condições de uso
`$addFields`	Em qualquer lugar
`$match`	Em qualquer lugar
`$project`	Em qualquer lugar
`$redact`	Em qualquer lugar
`$replaceRoot`	Em qualquer lugar
`$replaceWith`	Em qualquer lugar
`$set`	Em qualquer lugar
`$unset`	Em qualquer lugar
`$unwind`	Em qualquer lugar
`$group`	Somente dentro `$hoppingWindow` ou `$tumblingWindow` estágios.
`$sort`	Somente dentro `$hoppingWindow` ou `$tumblingWindow` estágios.
`$limit`	Somente dentro `$hoppingWindow` ou `$tumblingWindow` estágios.
`$count`	Somente dentro `$hoppingWindow` ou `$tumblingWindow` estágios.

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.

Alguns estágios principais do pipeline de agregação têm suporte limitado ou não são compatíveis, conforme observado na tabela a seguir. Se um estágio não estiver listado na tabela, o Atlas Stream Processing oferecerá suporte a ele.

Estágio de agregação	Status do suporte
`$group`	Compatível apenas em `$tumblingWindow` ou `$hoppingWindow`.
`$sort`	Compatível apenas em `$tumblingWindow` ou `$hoppingWindow`.
`$limit`	Compatível apenas em `$tumblingWindow` ou `$hoppingWindow`.
`$count`	Compatível apenas em `$tumblingWindow` ou `$hoppingWindow`.
`$merge`	Compatível com sintaxe modificada. Para obter mais informações, consulte `$merge`.
`$lookup`	Compatível com sintaxe modificada. Para obter mais informações, consulte `$lookup`.

Voltar

$convert

$source