FetchFile 2025.5.31.15¶

Bundle¶

org.apache.nifi | nifi-standard-nar

Beschreibung¶

Liest den Inhalt einer Datei von der Festplatte und streamt ihn in den Inhalt eines eingehenden FlowFile. Sobald dies geschehen ist, wird die Datei optional an einen anderen Ort verschoben oder gelöscht, um das Dateisystem übersichtlich zu halten.

Tags¶

fetch, files, filesystem, get, ingest, ingress, input, local, source

Eingabeanforderung¶

REQUIRED

Unterstützt sensible dynamische Eigenschaften¶

false

Eigenschaften¶

Eigenschaft	Beschreibung
Completion Strategy	Legt fest, was mit der Originaldatei im Dateisystem geschehen soll, nachdem sie in NiFi abgerufen wurde.
File to Fetch	Der vollqualifizierte Dateiname der Datei, die aus dem Dateisystem abgerufen werden soll
Log level when file not found	Protokolliergrad für den Fall, dass die Datei nicht vorhanden, wenn der Prozessor ausgelöst wird
Log level when permission denied	Protokolliergrad, der verwendet werden soll, wenn der aktuelle Benutzer der Anwendung nicht über ausreichende Berechtigungen zum Lesen der Datei verfügt
Move Conflict Strategy	Wenn die „Completion Strategy“ auf „Move File“ gesetzt ist und im Zielverzeichnis bereits eine Datei mit demselben Namen vorhanden ist, legt diese Eigenschaft fest, wie dieser Namenskonflikt gelöst werden soll.
Move Destination Directory	Das Verzeichnis, in das die Originaldatei verschoben werden soll, nachdem sie aus dem Dateisystem abgerufen wurde. Diese Eigenschaft wird ignoriert, wenn die „Completion Strategy“ nicht auf „Move File“ eingestellt ist. Wenn das Verzeichnis nicht existiert, wird es erstellt.

Einschränkungen¶

Erforderliche Berechtigung	Erläuterung
read filesystem	Bietet dem Bediener die Möglichkeit, aus jeder Datei zu lesen, auf die er NiFi Zugriff hat.
write filesystem	Bietet dem Operator die Möglichkeit, jede Datei zu löschen, auf die NiFi Zugriff hat.

Beziehungen¶

Name	Beschreibung
failure	Jedes FlowFile, das nicht aus dem Dateisystem abgerufen werden konnte, weil es keine ausreichenden Berechtigungen hat oder die Datei nicht existiert, wird an diese Beziehung übertragen.
not.found	Jedes FlowFile, das nicht aus dem Dateisystem abgerufen werden konnte, weil die Datei nicht gefunden wurde, wird an diese Beziehung übertragen.
permission.denied	Jedes FlowFile, das nicht aus dem Dateisystem abgerufen werden konnte, weil der Benutzer, der NiFi ausführt, nicht über ausreichende Berechtigungen verfügt, werden an diese Beziehung übertragen.
success	Jedes FlowFile, das erfolgreich aus dem Dateisystem abgerufen wird, wird an diese Beziehung übertragen.

Anwendungsfälle mit anderen Komponenten¶

Aufnahme aller Dateien aus einem Verzeichnis in NiFi

Aufnahme bestimmter Dateien aus einem Verzeichnis in NiFi durch Filtern nach Dateinamen