RunMongoAggregation 2025.10.2.19¶

Bundle¶

org.apache.nifi | nifi-mongodb-nar

Beschreibung¶

Ein Prozessor, der bei jedem Empfang eines FlowFile eine Aggregationsabfrage durchführt.

Tags¶

aggregate, aggregation, mongo

Eingabeanforderung¶

ALLOWED

Unterstützt sensible dynamische Eigenschaften¶

false

Eigenschaften¶

Eigenschaft	Beschreibung
Batch Size	Die Anzahl der vom Server in einem Batch zurückgegebenen Elemente.
Mongo Collection Name	Der Name der zu verwendenden Sammlung
Mongo Database Name	Der Name der zu verwendenden Datenbank
allow-disk-use	Setzen Sie diesen Wert auf „true“, um das Schreiben von Daten in temporäre Dateien zu aktivieren und so zu verhindern, dass die maximale Speicherbelegung während der Aggregations-Pipeline bei der Verarbeitung großer Datensätze überschritten wird.
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	Die auszuführende Abfrage zur Aggregation.
mongo-charset	Gibt den Zeichensatz der Dokumentdaten an.
mongo-client-service	Wenn diese Eigenschaft konfiguriert ist, wird der zugewiesene Client-Dienst für das Verbindungspooling verwendet.
mongo-date-format	Die Datumsformatzeichenfolge, die zum Formatieren von Datumsfeldern verwendet werden soll, die von Mongo zurückgegeben werden. Sie wird nur angewendet, wenn das JSON-Ausgabeformat auf Standard-JSON eingestellt ist.
mongo-query-attribute	Wenn diese Option gesetzt ist, wird die Abfrage in ein bestimmtes Attribut in den Ausgabe-FlowFiles geschrieben.
results-per-flowfile	Wie viele Ergebnisse auf einmal in ein FlowFile eingefügt werden sollen. Der gesamte Body wird als eine JSON Reihe von Ergebnissen behandelt.

Beziehungen¶

Name	Beschreibung
failure	Wenn die Abfrage fehlschlägt, wird die Eingabedatei an diese Beziehung gesendet.
original	Die Eingabedatei wird an diese Beziehung gesendet, wenn die Abfrage erfolgreich war.
results	Das Resultset der Aggregation wird an diese Beziehung gesendet.