ListDBFSDirectory 2025.5.31.15¶
Bundle¶
com.snowflake.openflow.runtime | runtime-databricks-processors-nar
Description¶
Liste les noms de fichiers dans un répertoire DBFS et génère un nouveau FlowFile en sortie avec le nom du fichier.
Exigences en matière d’entrées¶
Prend en charge les propriétés dynamiques sensibles¶
false
Propriétés¶
Propriété |
Description |
---|---|
DBFS File Path |
Chemin d’accès au fichier DBFS, par ex. /directory/file.txt |
Databricks Client |
Service client Databricks. |
Inclure les répertoires |
Inclut les répertoires dans les FlowFiles produits. |
Listing dans le répertoire récursif |
Liste récursivement les fichiers dans les sous-répertoires. |
Relations¶
Nom |
Description |
---|---|
failure |
Relation d’échec Databricks |
original |
Le FlowFile original est routé vers cette relation lorsque le traitement est réussi. |
success |
Relation de réussite Databricks |
Écrit les attributs¶
Nom |
Description |
---|---|
filename |
Nom de base du fichier ou du répertoire DBFS. |
path |
Chemin d’accès au répertoire parent contenant le fichier ou le répertoire DBFS. |
absolute.path |
Chemin complet vers le fichier ou le répertoire DBFS. |
dbfs.resourceType |
Le type de ressource, « fichier » ou « répertoire » de la ressource DBFS. |
dbfs.size |
La taille du fichier DBFS. |
dbfs.lastModifiedTime |
Dernière heure de modification du fichier DBFS, en millisecondes depuis l’époque dans le fuseau horaire UTC. |
error.code |
Code d’erreur de l’instruction SQL en cas d’erreur. |
error.message |
Message d’erreur de l’instruction SQL en cas d’erreur. |