Upload
Upload a file to Azure Data Lake Storage.
type: "io.kestra.plugin.azure.storage.adls.Upload"
Examples
Download a json file and upload it to Azure Data Lake Storage.
id: azure_data_lake_storage_upload
namespace: company.team
tasks:
- id: download_request
type: io.kestra.plugin.core.http.Download
uri: adls/product_data/product.json
- id: upload_file
type: io.kestra.plugin.azure.storage.adls.Upload
filePath: "path/to/file/product.json"
from: "{{ outputs.download_request.uri }}"
connectionString: "{{ secret('AZURE_CONNECTION_STRING') }}"
fileSystem: "tasks"
endpoint: "https://yourblob.blob.core.windows.net"
Properties
endpoint *Requiredstring
The blob service endpoint.
filePath *Requiredstring
File path
Full path of the file in its file system
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.
from *Requiredstring
The file from the internal storage to upload to the Azure Data Lake Storage.
Pebble expression referencing an Internal Storage URI e.g. {{ outputs.mytask.uri }}
.
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.
Outputs
file AdlsFile
The uploaded file.
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
archiveStatus ArchiveStatus
archiveTier AccessTier
contentEncoding string
contentLanguage string
contentMd5 string
contentType string
creationTime string
date-time
eTag string
fileName string
fileSystem string
group string
isDirectory boolean
lastModifed string
date-time
leaseDuration string
INFINITE
FIXED
leaseState string
AVAILABLE
LEASED
EXPIRED
BREAKING
BROKEN
leaseStatus string
LOCKED
UNLOCKED
name string
owner string
permissions string
size integer
uri string
uri