Upload a file to Azure Data Lake Storage.
yaml
type: "io.kestra.plugin.azure.storage.adls.List"
Examples
List all files and directories in a specific Azure Data Lake Storage directory and log each file data output.
yaml
id: azure_data_lake_storage_list
namespace: company.team
tasks:
- id: list_files_in_dir
type: io.kestra.plugin.azure.storage.adls.List
connectionString: "{{ secret('AZURE_CONNECTION_STRING') }}"
fileSystem: "tasks"
endpoint: "https://yourblob.blob.core.windows.net"
directoryPath: "path/to/my/directory/"
- id: for_each_file
type: io.kestra.plugin.core.flow.EachParallel
value: "{{ outputs.list_files_in_dir.files }}"
tasks:
- id: log_file_name
type: io.kestra.plugin.core.debug.Echo
level: DEBUG
format: "{{ taskrun.value }}"
Properties
directoryPath *Requiredstring
Directory path
Full path to the directory
endpoint *Requiredstring
The blob service endpoint.
fileSystem *Requiredstring
The name of the file systems. If the path name contains special characters, pass in the url encoded version of the path name.
connectionString string
Connection string of the Storage Account.
sasToken string
The SAS token to use for authenticating requests.
This string should only be the query parameters (with or without a leading '?') and not a full URL.
Definitions
com.azure.storage.file.datalake.models.AccessTier
com.azure.storage.file.datalake.models.ArchiveStatus
io.kestra.plugin.azure.storage.adls.models.AdlsFile
accessControlList array
SubType string
archiveStatus ArchiveStatus
archiveTier AccessTier
contentEncoding string
contentLanguage string
contentMd5 string
contentType string
creationTime string
Format
date-time
eTag string
fileName string
fileSystem string
group string
isDirectory boolean
lastModifed string
Format
date-time
leaseDuration string
Possible Values
INFINITE
FIXED
leaseState string
Possible Values
AVAILABLE
LEASED
EXPIRED
BREAKING
BROKEN
leaseStatus string
Possible Values
LOCKED
UNLOCKED
name string
owner string
permissions string
size integer
uri string
Format
uri