Menu Docs

Página inicial do DocsDesenvolver aplicaçõesManual do MongoDB

Estágios de aggregation

Nesta página

  • Compatibilidade
  • db.collection.agregado() Estágios
  • db.agregado() Estágios
  • Estágios disponíveis para atualizações

Nos métodos db.collection.aggregate() e db.aggregate() , os estágios do pipeline aparecem em uma matriz. Na interface do usuário do Atlas, você pode organizar os estágios do pipeline usando oconstrutor de pipeline de agregação . Os documentos passam pelas etapas em sequência.

Você pode usar as etapas de pipeline para implantações hospedadas nos seguintes ambientes:

  • MongoDB Atlas: o serviço totalmente gerenciado para implantações MongoDB na nuvem

Todas as etapas, exceto as fases $out, $merge, $geoNear, $changeStream e $changeStreamSplitLargeEvent, podem aparecer várias vezes em um pipeline.

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.

db.collection.aggregate( [ { <stage> }, ... ] )
Estágio
Descrição
$addFields

Adiciona novos campos aos documentos. Semelhante ao $project, $addFields remodela cada documento no fluxo; especificamente, adicionando novos campos aos documentos de saída que contêm os campos existentes dos documentos de entrada e os campos recém-adicionados.

$set é um alias para $addFields.

Categoriza documentos recebidos em grupos, chamados blocos, com base em uma expressão especificada e limites de blocos.
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.
Retorna um cursor Alterar coluna para a coleção. Esse estágio só pode ocorrer uma vez em um pipeline de agregação e deve ocorrer como o primeiro estágio.

Divide change stream grandes que excedem 16 MB em fragmentos menores retornados em um cursor de change stream de alterações.

Você só pode usar $changeStreamSplitLargeEvent em um pipeline $changeStream e ele deve ser o estágio final no pipeline.

Retorna estatísticas sobre uma coleção ou visualização.

Retorna uma contagem do número de documentos nesta etapa do pipeline de agregação.

Distinto do acumulador de agregação do $count.

Cria novos documentos em uma sequência de documentos onde determinados valores em um campo estão faltando.

Retorna documentos literais de expressões de entrada.
Processa vários aggregation pipelines em um único estágio 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.

Preenche null e os valores de campo ausentes nos documentos.

Retorna um fluxo ordenado de documentos baseado na proximidade de um ponto geoespacial. Incorpora a funcionalidade do $match, $sort e $limit para dados geoespaciais. Os documentos de saída incluem um campo de distância adicional e podem incluir um campo de identificador de local.

Executa uma pesquisa recursiva em uma coleção. Para cada documento de saída, adiciona um novo campo de matriz que contém resultados transversais da busca recursiva por esse documento.
Agrupa documentos de entrada por uma expressão de identificador especificada e aplica a(s) expressão(ões) acumuladora(s), se especificada(s), para cada grupo. Consome todos os documentos de entrada e gera um documento por cada grupo distinto. Os documentos de saída só contêm o campo identificador e, se especificado, campos acumulados.
Retorna estatísticas sobre o uso de cada índice para a coleção.
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).
Lista queries de amostra para todas as collections ou para uma collection específica.

Retorna informações sobre Atlas Search indexes em uma coleção especificada.

Lista todas as sessões que estão ativas há muito tempo para propagar para a coleção system.sessions.
Executa uma junção externa esquerda a outra collection no mesmo banco de dados para filtrar documentos da collection "associada" para processamento.
Filtra o fluxo de documentos para permitir que apenas documentos correspondentes passem sem modificações para o próximo estágio do pipeline. O $match utiliza consultas MongoDB padrão. Para cada documento de entrada, gera um documento (uma correspondência) ou zero documentos (nenhuma correspondência).

Escreve os documentos resultantes do aggregation 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 o estágio $merge , ele deve ser o último estágio do pipeline.

Novidades na versão 4.2.

Escreve os documentos resultantes do aggregation pipeline em uma coleção. Para usar o estágio $out, ele deve ser o último estágio no pipeline.
Retorna informações de cache do plano para uma coleção.

Remodela cada documento no fluxo, adicionando novos campos ou removendo campos existentes. Para cada documento de entrada, gera um documento.

Consulte também $unset para remover campos existentes.

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 redação em nível de campo. Para cada documento de entrada, gera um ou zero documentos.

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.

$replaceWith é um alias para o estágio $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.

$replaceWith é um alias para o estágio $replaceRoot.

Seleciona aleatoriamente o número especificado de documentos de sua entrada.

Realiza uma procurar de texto completo do campo ou campos em uma collection do Atlas .

Observação

$search está disponível apenas para clusters do MongoDB Atlas, e não está disponível para implementações auto-gerenciadas. Para saber mais, consulte Estágios de aggregation pipeline do Atlas Search.

Retorna diferentes tipos de documentos de resultado de metadados para a query Pesquisa do Atlas em relação a uma collection do Atlas .

Observação

$searchMeta está disponível apenas para clusters MongoDB Atlas executando MongoDB v4.4.9 ou superior e não está disponível para sistemas autogerenciados. Para saber mais, consulte Estágios de aggregation pipeline do Atlas Search.

Adiciona novos campos aos documentos. Semelhante ao $project, $set remodela cada documento no fluxo; especificamente, adicionando novos campos aos documentos de saída que contêm os campos existentes dos documentos de entrada e os campos recém-adicionados.

$set é um alias para o estágio $addFields.

Agrupa documentos em janelas e aplica um ou mais operadores aos documentos em cada janela.

Novidades na versão 5,0.

Ignora os primeiros n documentos, em que 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).
Reordena o fluxo de documentos por uma chave de classificação especificada. Apenas a ordem muda; os documentos permanecem inalterados. Para cada documento de entrada, gera um documento.
Agrupa documentos recebidos com base no valor de uma expressão especificada e, em seguida, calcula a contagem de documentos em cada grupo distinto.
Executa uma união de duas coleções; ou seja, combina resultados de pipeline de duas coleções em um único conjunto de resultados.

Remove/exclui campos dos documentos.

$unset é um alias para o estágio $project que remove campos.

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 e pode ser zero para uma array vazia.

Realiza uma pesquisa ANN em um vetor no campo especificado de uma coleção do Atlas .

Novidades na versão 7.0.2.

Observação

$vectorSearch está disponível apenas para clusters MongoDB Atlas executando MongoDB v6.0.11 ou superior e não está disponível para sistemas autogerenciados. Para saber mais, consulte Estágios de aggregation pipeline do Atlas Search.

Para saber quais operadores de expressão de agregação usar nos estágios do pipeline, consulte Operadores de agregação.

O MongoDB também fornece o método db.aggregate() :

db.aggregate( [ { <stage> }, ... ] )

As seguintes etapas utilizam o método db.aggregate() e não o método db.collection.aggregate().

Estágio
Descrição
Retorna um cursor Alterar coluna para a coleção. Esse estágio só pode ocorrer uma vez em um pipeline de agregação e deve ocorrer como o primeiro estágio.
Retorna informações sobre operações ativas e/ou dormentes para a implementação do MongoDB.
Retorna documentos literais de valores de entrada.
Lista todas as sessões ativas recentemente em uso na mongos ou instânciamongod conectada no momento. Essas sessões podem ainda não ter sido propagadas para a coleção system.sessions.

A partir do MongoDB 4.2, você pode usar o pipeline de agregação para atualizações em:

Comando
mongosh Métodos

Para as atualizações, o pipeline pode consistir nos seguintes estágios:

← Comandos de agregação