PutMongo 2025.5.31.15¶

Bundle¶

org.apache.nifi | nifi-mongodb-nar

Beschreibung¶

Schreibt den Inhalt eines FlowFile in MongoDB

Tags¶

insert, mongodb, put, update, write

Eingabeanforderung¶

REQUIRED

Unterstützt sensible dynamische Eigenschaften¶

false

Eigenschaften¶

Eigenschaft	Beschreibung
Zeichensatz	Der Zeichensatz, in dem die Daten codiert sind
Modus	Gibt an, ob der Prozessor Inhalte einfügen oder aktualisieren soll
Mongo Collection Name	Der Name der zu verwendenden Sammlung
Mongo Database Name	Der Name der zu verwendenden Datenbank
Update Method	MongoDB-Methode zum Ausführen von Aktualisierungsvorgängen für Sammlungen, z. B. „updateOne“ oder „updateMany“.
Update Query Key	Ein oder mehrere durch Kommas getrennte Namen von Dokumentschlüsseln, die zur Erstellung der Abfragekriterien für die Aktualisierung verwendet werden, z. B. _id
Upsert	Bei „true“ wird ein Dokument eingefügt, wenn kein Dokument den Kriterien der Aktualisierungsabfrage entspricht. Diese Eigenschaft ist nur im Aktualisierungsmodus gültig, andernfalls wird sie ignoriert.
mongo-client-service	Wenn diese Eigenschaft konfiguriert ist, wird der zugewiesene Client-Dienst für das Verbindungspooling verwendet.
put-mongo-update-mode	Wählen Sie einen Aktualisierungsmodus. Sie können entweder ein JSON-Dokument angeben, das als direkter Ersatz verwendet wird, oder ein Dokument, das Aktualisierungsoperatoren wie $set, $unset und $inc enthält. Wenn der Operatormodus aktiviert ist, wird erwartet, dass der Inhalt des FlowFile der Operatorteil ist, zum Beispiel: {$set:{„key“: „value“}, $inc:{„count“:1234}}, und die Aktualisierungsabfrage kommt aus der konfigurierten Eigenschaft „Update Query“ (Aktualisierungsabfrage).
putmongo-update-query	Geben Sie eine vollständige MongoDB-Abfrage an, die für die Suchabfrage verwendet werden soll, um eine Aktualisierung/ein Upsert durchzuführen. NOTE: Dieses Feld wird ignoriert, wenn der Wert „Update Query Key“ nicht leer ist.

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.

Schreibt Attribute¶

Name	Beschreibung
mongo.put.update.match.count	Die Anzahl der Übereinstimmungen aus dem Ergebnis, wenn eine Aktualisierung/Einfügung durchgeführt wird, andernfalls nicht gesetzt.
mongo.put.update.modify.count	Die Änderungsanzahl aus dem Ergebnis, wenn eine Aktualisierung/Einfügung durchgeführt wird, andernfalls nicht gesetzt.
mongo.put.upsert.id	Der Hexadezimalwert „_id“, wenn „upsert“ ausgeführt wird, andernfalls nicht festgelegt.