Estágios do pipeline de agregação

Visão geral

Neste guia, você pode aprender a criar um pipeline de agregação e estágios de pipeline usando métodos no driver MongoDB Node.js

Criar um pipeline de agregação

Você pode usar o driver Node.js para construir um pipeline de agregação criando uma variável de pipeline ou passando estágios de agregação diretamente para o método de agregação . Veja os exemplos a seguir para saber mais sobre cada uma dessas abordagens.

// Defines the aggregation pipeline
const pipeline = [
  { $match: { ... } },
  { $group: { ... } }
];
// Executes the aggregation pipeline
const results = await collection.aggregate(pipeline);

// Defines and executes the aggregation pipeline
const results = await collection.aggregate([
  { $match: { ... } },
  { $group: { ... } }
]);

Métodos de estágio de agregação

A tabela a seguir lista os estágios no agregação pipeline. Para saber mais sobre um estágio de agregação e ver um exemplo de código em um aplicação Node.js , siga o link do nome do estágio para sua página de referência no manual do MongoDB Server .

Estágio	Descrição
$addFields	Adiciona novos campos aos documentos. Produz documentos que contêm os campos existentes dos documentos de entrada e os campos recém-adicionados. `$set` é um alias para `$addFields`.
$bucket	Categoriza documentos recebidos em grupos, chamados blocos, com base em uma expressão especificada e limites de blocos.
$bucketAuto	Categoriza documentos recebidos em um número específico de grupos, chamados blocos, com base em uma expressão especificada. Os limites dos compartimentos são determinados automaticamente em uma tentativa de distribuir uniformemente os documentos no número especificado de compartimentos.
$changeStream	Retorna um cursor de fluxo de alterações para a coleção. Deve ser o primeiro estágio do pipeline. `$changeStream` retorna um `AggregationCursor` quando passado para o método `aggregate()` e um `ChangeStreamCursor` quando passado para o método `watch()`.
$changeStreamSplitLargeEvent	Divide change stream grandes que excedem 16 MB em fragmentos menores retornados em um cursor de change stream de alterações. Deve ser o último estágio do pipeline. `$changeStreamSplitLargeEvent` retorna um `AggregationCursor` quando passado para o método `aggregate()` e um `ChangeStreamCursor` quando passado para o método `watch()`.
$collStats	Retorna estatísticas sobre uma coleção ou visualização.
$count	Retorna uma contagem do número de documentos nesta etapa do pipeline de agregação.
$operação atual	Retorna um fluxo de documentos contendo informações sobre operações ativas e dormentes e quaisquer sessões inativas que estejam retendo bloqueios como parte de uma transação.
$densify	Cria novos documentos em uma sequência de documentos onde determinados valores em um campo estão faltando.
$documentos	Retorna documentos literais de expressões de entrada.
$facet	Processa vários pipelines de agregação em uma única fase no mesmo conjunto de documentos de entrada. Permite a criação de agregações multifacetadas capazes de caracterizar dados em várias dimensões, ou facets, em um único estágio.
$geoNear	Retorna documentos na ordem do mais próximo para o mais distante de um ponto especificado . Este método adiciona um campo aos documentos de saída que contém a distância do ponto especificado .
$graphLookup	Executa uma pesquisa recursiva em uma coleção. Este método adiciona um novo campo de array a cada documento de saída que contém os resultados transversais da pesquisa recursiva para esse documento.
$group	Agrupa documentos de entrada por uma expressão de identificador especificada e aplica as expressões acumulador , se especificadas, a cada grupo. Consome todos os documentos de entrada e gera um documento por cada grupo distinto. Os documentos de saída contêm apenas o campo identificador e, se especificado, campos acumulados.
$indexStats	Retorna estatísticas sobre o uso de cada índice para a coleção.
$limit	Passa os primeiros n documentos não modificados para o pipeline, onde n é o limite especificado. Para cada documento de entrada, gera um documento (para os primeiros n documentos) ou zero documentos (após os primeiros n documentos).
$listSampledQueries	Lista queries de amostra para todas as collections ou uma collection específica. Disponível apenas para collections com a Queryable Encryption ativada.
$listSearchIndexes	Retorna informações sobre os índices existentes do Atlas Search em uma collection especificada.
$lookup	Executa uma junção externa esquerda a outra collection no mesmo banco de dados para filtrar documentos da collection "associada" para processamento.
$match	Filtra o fluxo de documentos para permitir que apenas documentos correspondentes passem sem modificações para o próximo estágio do pipeline. Para cada documento de entrada, gera um documento (uma correspondência) ou zero documentos (nenhuma correspondência).
$merge	Escreve os documentos resultantes do agregação pipeline em uma coleção. O estágio pode incorporar (inserir novos documentos, mesclar documentos, substituir documentos, manter documentos existentes, falhar na operação, processar documentos com um pipeline de atualização personalizado) os resultados em uma coleção de saída. Para usar esse estágio, ele deve ser o último estágio do pipeline.
$out	Escreve os documentos resultantes do agregação pipeline em uma coleção. Para usar esse estágio, ele deve ser o último estágio do pipeline.
$project	Remodela cada documento no fluxo, adicionando novos campos ou removendo campos existentes. Para cada documento de entrada, gera um documento.
$redact	Remodela cada documento no fluxo restringindo o conteúdo de cada documento com base nas informações armazenadas nos próprios documentos. Incorpora a funcionalidade do `$project` e `$match`. Pode ser usado para implementar a supressão em nível de campo . Para cada documento de entrada, gera um ou zero documentos.
$replaceRoot	Substitui um documento pelo documento incorporado especificado. A operação substitui todos os campos existentes no documento de entrada, incluindo o campo `_id`. Especifique um documento incorporado no documento de entrada para promover o documento incorporado ao nível superior. O estágio `$replaceWith` é um alias para o estágio `$replaceRoot`.
$replaceWith	Substitui um documento pelo documento incorporado especificado. A operação substitui todos os campos existentes no documento de entrada, incluindo o campo `_id`. Especifique um documento incorporado no documento de entrada para promover o documento incorporado ao nível superior. O estágio `$replaceWith` é um alias para o estágio `$replaceRoot`.
$sample	Seleciona aleatoriamente o número especificado de documentos de sua entrada.
$search	Realiza uma Full Text Search do campo ou campos em uma coleção do Atlas. Esse estágio está disponível apenas para clusters do MongoDB Atlas , e não está disponível para implementações autogerenciadas. Para saber mais, consulte Estágios de aggregation pipeline do Atlas Search na documentação do Atlas.
$searchMeta	Retorna diferentes tipos de documentos de resultado de metadados para a query Pesquisa do Atlas em relação a uma coleção do Atlas. Esse estágio está disponível apenas para clusters do MongoDB Atlas , e não está disponível para implementações autogerenciadas. Para saber mais, consulte Estágios de aggregation pipeline do Atlas Search na documentação do Atlas.
$set	Adiciona novos campos aos documentos. Como o método `Project()`, esse método remodela cada documento no fluxo adicionando novos campos aos documentos de saída que contêm os campos existentes dos documentos de entrada e os campos recém-adicionados.
$setWindowFields	Agrupa documentos em janelas e aplica um ou mais operadores aos documentos em cada janela.
$skip	Ignora os primeiros n documentos, onde n é o número de pulos especificado, e passa os documentos restantes sem modificações para o pipeline. Para cada documento de entrada, produz zero documentos (para os primeiros n documentos) ou um documento (se após os primeiros n documentos).
$sort	Reordena o fluxo de documento por uma chave de classificação especificada. Os documentos permanecem inalterados. Para cada documento de entrada, gera um documento.
$sortByCount	Agrupa documentos recebidos com base no valor de uma expressão especificada e, em seguida, calcula a contagem de documentos em cada grupo distinto.
$unionWith	Combina os resultados do pipeline de duas collections em um único conjunto de resultados.
$unset	Remove/exclui campos dos documentos. `$unset` é um alias para `$project` que remove campos.
$unwind	Desconstrói um campo de array a partir dos documentos de entrada para gerar um documento para cada elemento. Cada documento de saída substitui a array por um valor de elemento. Para cada documento de entrada, produz n Documentos, onde n é o número de elementos de array. n pode ser zero para uma array vazia.
$vectorSearch	Executa uma pesquisa ANN ou ENN em um vetor no campo especificado de uma coleção Atlas. Esse estágio está disponível apenas para clusters do MongoDB Atlas , e não está disponível para implementações autogerenciadas. Para saber mais, consulte Atlas Vector Search.

Documentação da API

Para saber mais sobre como montar um pipeline de agregação, consulte Aggregation Pipeline no manual do MongoDB Server.

Para saber mais sobre como criar estágios de pipeline, consulte Estágios de agregação no manual do MongoDB Server .

Para obter mais informações sobre os métodos e as classes usadas nesta página, consulte a seguinte documentação da API:

Voltar

Agregação

Data Formats