FetchGridFS 2025.5.31.15

Bundle

org.apache.nifi | nifi-mongodb-nar

Beschreibung

Ruft eine oder mehrere Dateien aus einem GridFS-Bucket nach Dateinamen oder durch eine benutzerdefinierte Abfrage ab.

Tags

fetch, gridfs, mongo

Eingabeanforderung

REQUIRED

Unterstützt sensible dynamische Eigenschaften

false

Eigenschaften

Eigenschaft

Beschreibung

gridfs-bucket-name

Der GridFS-Bucket, in dem die Dateien gespeichert werden sollen. Wenn Sie nichts eingeben, wird der Standardwert „fs“ verwendet, den der MongoDBClient-Treiber verwendet.

gridfs-client-service

Der MongoDB-Client-Dienst, der für Datenbankverbindungen verwendet wird.

gridfs-database-name

Der Name der zu verwendenden Datenbank

gridfs-file-name

Der Name der Datei im Bucket, die das Ziel dieses Prozessors ist.

gridfs-query

Eine gültige MongoDB-Abfrage, mit der Sie eine oder mehrere Dateien von GridFS abrufen können.

mongo-operation-mode

Diese Option steuert, wann die Ergebnisse den nachgelagerten Prozessoren zur Verfügung gestellt werden. Wenn „Stream Query Results“ aktiviert ist, wird die Herkunft nicht relativ zum Eingabe-FlowFile verfolgt, wenn ein Eingabe-FlowFile empfangen wird und die Abfrage startet. Im Modus „Stream Query Results“ werden Fehler behandelt, indem ein neues FlowFile mit dem ursprünglichen Inhalt und den Attributen des Eingabe-FlowFiles an die Beziehung „failure“ gesendet wird. Streaming sollte nur verwendet werden, wenn eine zuverlässige Konnektivität zwischen MongoDB und NiFi besteht.

mongo-query-attribute

Wenn diese Option gesetzt ist, wird die Abfrage in ein bestimmtes Attribut in den Ausgabe-FlowFiles geschrieben.

Beziehungen

Name

Beschreibung

failure

Wenn die Verarbeitung des FlowFiles fehlschlägt, geht es an diese Beziehung.

original

Das Original-Eingabe-FlowFile geht an diese Beziehung, wenn die Abfrage keinen Fehler verursacht.

success

Wenn die Operation erfolgreich ist, wird das Flowfile an diese Beziehung gesendet.

Schreibt Attribute

Name

Beschreibung

gridfs.file.metadata

Die mit einer Datei gespeicherten benutzerdefinierten Metadaten werden an diese Eigenschaft angehängt, wenn sie vorhanden sind.