GetMongo 2025.5.31.15

Bundle

org.apache.nifi | nifi-mongodb-nar

Beschreibung

Erstellt FlowFiles aus Dokumenten in MongoDB, die durch eine vom Benutzer angegebene Abfrage geladen wurden.

Tags

get, mongodb, read

Eingabeanforderung

ALLOWED

Unterstützt sensible dynamische Eigenschaften

false

Eigenschaften

Eigenschaft

Beschreibung

Batch Size

Die Anzahl der Elemente, die vom Server in einem Batch zurückgegeben werden sollen

Limit

Die maximale Anzahl der zurückzugebenden Elemente

Mongo Collection Name

Der Name der zu verwendenden Sammlung

Mongo Database Name

Der Name der zu verwendenden Datenbank

Projection

Die Felder, die aus den Dokumenten im Resultset zurückgegeben werden sollen; muss ein gültiges BSON-Dokument sein

Abfrage

Die Auswahlkriterien, nach denen der Lookup erfolgen soll. Wenn das Feld leer gelassen wird, wird nach einer eingehenden Verbindung von einem anderen Prozessor gesucht, um die Abfrage als gültiges JSON-Dokument innerhalb des Bodys des FlowFile bereitzustellen. Wenn dieses Feld leer gelassen wird und ein Timer anstelle einer eingehenden Verbindung aktiviert ist, führt dies zu einem vollständigen Abruf der Sammlung mit einer „{}“-Abfrage.

Sort

Die Felder, nach denen sortiert werden soll; muss ein gültiges BSON-Dokument sein

get-mongo-send-empty

Wenn eine Abfrage erfolgreich ausgeführt wird, aber keine Ergebnisse zurückgibt, senden Sie ein leeres JSON-Dokument, das angibt, dass kein Ergebnis vorliegt.

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-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 eingegeben werden sollen. Der gesamte Body wird als eine JSON Reihe von Ergebnissen behandelt.

use-pretty-printing

Legen Sie fest, ob die JSON aus den Ergebnissen der Abfrage formatiert (pretty print) werden soll oder nicht. Die Auswahl von „true“ kann den Speicherplatzbedarf auf der Festplatte je nach Komplexität des JSON-Dokuments erheblich erhöhen.

Beziehungen

Name

Beschreibung

failure

Alle Eingabe-FlowFiles, die Teil einer fehlgeschlagenen Abfrageausführung sind, werden hierher weitergeleitet.

original

Alle Eingabe-FlowFiles, die zu einer erfolgreichen Ausführung der Abfrage gehören, werden hier abgelegt.

success

Alle FlowFiles, die die Ergebnisse einer erfolgreichen Abfrage enthalten, werden hier abgelegt.

Schreibt Attribute

Name

Beschreibung

mongo.database.name

Die Datenbank, aus der die Ergebnisse stammen.

mongo.collection.name

Die Sammlung, aus der die Ergebnisse stammen.