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.
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. |