ListDBFSDirectory 2025.5.31.15¶
Bundle¶
com.snowflake.openflow.runtime | runtime-databricks-processors-nar
Beschreibung¶
Listet die Dateinamen in einem DBFS-Verzeichnis auf und gibt ein neues FlowFile mit dem Dateinamen aus.
Eingabeanforderung¶
Unterstützt sensible dynamische Eigenschaften¶
false
Eigenschaften¶
Eigenschaft |
Beschreibung |
---|---|
DBFS File Path |
DBFS-Dateipfad z. B. /directory/file.txt |
Databricks Client |
Databricks-Client Service. |
Include Directories |
Verzeichnisse in produzierte FlowFiles einbeziehen. |
Recursive Directory Listing |
Dateien in Unterverzeichnissen rekursiv auflisten. |
Beziehungen¶
Name |
Beschreibung |
---|---|
failure |
Databricks-Beziehung „failure“ |
original |
Das Original-FlowFile wird bei erfolgreicher Bearbeitung an diese Beziehung weitergeleitet. |
success |
Databricks-Beziehung „success“ |
Schreibt Attribute¶
Name |
Beschreibung |
---|---|
filename |
Basisdateiname der/des DBFS-Datei oder -Verzeichnisses. |
Pfad |
Pfad zum übergeordneten Verzeichnis, das die/das DBFS-Datei oder -Verzeichnis enthält. |
absolute.path |
Vollständiger Pfad zu der/dem DBFS-Datei oder -Verzeichnis. |
dbfs.resourceType |
Der Typ der Ressource – „file“ oder „directory“ der DBFS-Ressource. |
dbfs.size |
Die Größe der DBFS-Datei. |
dbfs.lastModifiedTime |
Der letzte Änderungszeitpunkt der DBFS-Datei in Millisekunden seit der Epoche in UTC-Zeit. |
error.code |
Der Fehlercode für die SQL-Anweisung , wenn ein Fehler aufgetreten ist. |
error.message |
Die Fehlermeldung für die SQL-Anweisung, wenn ein Fehler aufgetreten ist. |