RunMongoAggregation 2025.5.31.15¶

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	Der Java-Treiber von MongoDB gibt standardmäßig „extended JSON“ zurück. Einige Features dieser Variante von JSON können bei anderen JSON-Parsern, die nur die Standardtypen und -konventionen von JSON erwarten, Probleme verursachen. Diese Konfigurationseinstellung steuert, ob Sie die erweitertes JSON verwenden oder eine saubere Ansicht bereitstellen, die dem Standard-JSON entspricht.
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.