
Upload
Upload a file to Azure Data Lake Storage.
Upload a file to Azure Data Lake Storage.
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 }}.
connectionStringstring
Connection string of the Storage Account.
leaseDurationSecondsintegerstring
Lease duration in seconds (between 15 and 60).
sasTokenstring
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.
useLeasebooleanstring
Enable blob lease before upload to prevent concurrent writes.
Outputs
file
The uploaded file.
io.kestra.plugin.azure.storage.adls.models.AdlsFile
com.azure.storage.file.datalake.models.ArchiveStatus
com.azure.storage.file.datalake.models.AccessTier
date-timedate-timeINFINITEFIXEDAVAILABLELEASEDEXPIREDBREAKINGBROKENLOCKEDUNLOCKEDuriMetrics
file.sizecounter
The size of the uploaded file, in bytes.