PutMongoRecord 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-mongodb-nar
Beschreibung¶
Dieser Prozessor ist ein datensatzbasiert Prozessor zum Einfügen/Upload von Daten in MongoDB. Es verwendet einen konfigurierten Datensatzleser und ein Schema, um eine eingehende Datensatzmenge aus dem Body eines FlowFile zu lesen und fügt dann Stapel dieser Datensätze in eine konfigurierte MongoDB-Sammlung ein/ein. Dieser Prozessor unterstützt keine Löschvorgänge. Die Anzahl der Dokumente, die gleichzeitig eingefügt werden, wird über die Konfigurationseigenschaft „Batch Size“ gesteuert. Dieser Wert sollte auf eine vernünftige Größe eingestellt werden, um sicherzustellen, dass MongoDB nicht mit zu vielen Operationen auf einmal überlastet wird.
Eingabeanforderung¶
REQUIRED
Unterstützt sensible dynamische Eigenschaften¶
false
Eigenschaften¶
Eigenschaft |
Beschreibung |
|---|---|
Mongo Collection Name |
Der Name der zu verwendenden Sammlung |
Mongo Database Name |
Der Name der zu verwendenden Datenbank |
bypass-validation |
Aktivieren oder deaktivieren Sie das Umgehen der Dokumentenschema-Validierung während Einfüge- oder Aktualisierungsoperationen. Die Umgehung der Dokumentvalidierung ist eine Aktion mit Berechtigung in MongoDB. Die Aktivierung dieser Eigenschaft kann bei Benutzern mit eingeschränkten Berechtigungen zu Autorisierungsfehlern führen. |
insert_count |
Die Anzahl der Datensätze, die für eine einzelne Einfüge-/Upsert-Operation in MongoDB gruppiert werden sollen. |
mongo-client-service |
Wenn diese Eigenschaft konfiguriert ist, wird der zugewiesene Client-Dienst für das Verbindungspooling verwendet. |
ordered |
Geordnete oder ungeordnete Operationen durchführen |
record-reader |
Gibt den Controller Service an, der für das Parsen eingehender Daten und die Bestimmung des Datenschemas verwendet werden soll |
update-key-fields |
Eine durch Kommas getrennte Liste von Feldern, anhand derer Dokumente identifiziert werden, die aktualisiert werden müssen. Wenn diese Eigenschaft festgelegt ist, versucht NiFi bei allen Dokumenten eine Upsert-Operation. Wenn diese Eigenschaft nicht gesetzt ist, werden alle Dokumente aufgenommen. |
update-mode |
Wählen Sie zwischen der Aktualisierung eines einzelnen Dokuments oder mehrerer Dokumente pro eingehendem Datensatz. |
Beziehungen¶
Name |
Beschreibung |
|---|---|
failure |
Alle FlowFiles, die nicht auf MongoDB geschrieben werden können, werden an diese Beziehung weitergeleitet. |
success |
Alle FlowFiles, die in MongoDB geschrieben werden, werden an diese Beziehung weitergeleitet. |