RunMongoAggregation 2025.5.31.15¶

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	Por padrão, o driver Java do MongoDBretorna “JSON estendido”. Alguns dos recursos dessa variante de JSON podem causar problemas para outros analisadores de JSON que esperam apenas tipos e convenções padrão de JSON. Essa definição de configuração controla o uso do JSON estendido ou o fornecimento de uma exibição limpa em conformidade com o JSON padrão.
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.