RunMongoAggregation 2025.10.2.19¶

Pacote¶

org.apache.nifi | nifi-mongodb-nar

Descrição¶

Um processador que executa uma consulta de agregação sempre que um FlowFile é recebido.

Tags¶

aggregate, aggregation, mongo

Requisito de entrada¶

ALLOWED

Oferece suporte a propriedades dinâmicas confidenciais¶

falso

Propriedades¶

Propriedade	Descrição
Tamanho do lote	O número de elementos retornados do servidor em um lote.
Nome da coleção Mongo	O nome da coleção a ser usada
Nome do banco de dados Mongo	O nome do banco de dados a ser usado
allow-disk-use	Defina essa opção como verdadeiro para permitir a gravação de dados em arquivos temporários e evitar que o limite máximo de uso de memória seja excedido durante o pipeline de agregação em estágios ao lidar com grandes conjuntos de dados.
json-type	By default, MongoDB’s Java driver returns «extended JSON». Some of the features of this variant of JSON may cause problems for other JSON parsers that expect only standard JSON types and conventions. This configuration setting controls whether to use extended JSON or provide a clean view that conforms to standard JSON.
mongo-agg-query	A consulta de agregação a ser executada.
mongo-charset	Especifica o conjunto de caracteres dos dados do documento.
mongo-client-service	Se configurada, essa propriedade usará o serviço de cliente atribuído para o pool de conexões.
mongo-date-format	A cadeia de caracteres de formato de data a ser usada para formatar os campos Date retornados do Mongo. Ela só é aplicada quando o formato de saída JSON está definido como JSON padrão.
mongo-query-attribute	Se definido, a consulta será gravada em um atributo especificado nos FlowFiles de saída.
results-per-flowfile	Quantos resultados devem ser colocados em um FlowFile de uma só vez. O corpo inteiro será tratado como uma matriz JSON de resultados.

Relações¶

Nome	Descrição
failure	O FlowFile de entrada é enviado para essa relação quando a consulta falha.
original	O FlowFile de entrada é enviado para essa relação quando a consulta é bem-sucedida.
resultados	O conjunto de resultados da agregação será enviado para essa relação.