GetMongoRecord 2025.5.31.15¶

Bundle¶

org.apache.nifi | nifi-mongodb-nar

Beschreibung¶

Eine datensatzbasierte Version von GetMongo, die von den Record Writers verwendet wird, um das Resultset MongoDB zu schreiben.

Tags¶

fetch, get, json, mongo, mongodb, record

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-record-writer-factory	Der Record Writer, der zum Schreiben der Resultsets verwendet wird.
mongo-client-service	Wenn diese Eigenschaft konfiguriert ist, wird der zugewiesene Client-Dienst für das Verbindungspooling verwendet.
mongo-query-attribute	Wenn diese Option gesetzt ist, wird die Abfrage in ein bestimmtes Attribut in den Ausgabe-FlowFiles geschrieben.
mongodb-schema-name	Der Name des Schemas in der konfigurierten Schema-Registry, das für die Abfrageergebnisse verwendet werden soll.

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.