Azure Upload

Azure Upload

Certified

Upload a file to Azure Data Lake Storage

Uploads a Kestra internal file to ADLS; optionally acquires a short lease via Blob API to avoid concurrent writes. Lease duration defaults to 15s and is clamped to Azure's 15–60s limits.

yaml
type: io.kestra.plugin.azure.storage.adls.Upload

Download a json file and upload it to Azure Data Lake Storage.

yaml
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

Service endpoint URL

Base HTTPS endpoint of the target service.

File path

Full path of the file in its file system

The name of the file systems. If the path name contains special characters, pass in the url encoded version of the path name

Source file

kestra:// URI from internal storage to upload

Connection string of the Storage Account.

Lease duration (s)

Lease duration between 15 and 60 seconds; values are clamped

Reference (ref) of the pluginDefaults to apply to this task.

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.

Shared Key access key for authenticating requests.

Shared Key account name for authenticating requests.

Use lease

Acquire blob lease before upload to prevent concurrent writers

Validate checksum

Compute MD5 client-side and pass it to Azure for server-side integrity verification; on mismatch the upload fails with Md5Mismatch

Uploaded file

Definitions
accessControlListarray
SubTypestring
archiveStatus
archiveTier
contentEncodingstring
contentLanguagestring
contentMd5string
contentTypestring
creationTimestring
Formatdate-time
eTagstring
fileNamestring
fileSystemstring
groupstring
isDirectoryboolean
lastModifedstring
Formatdate-time
leaseDurationstring
Possible Values
INFINITEFIXED
leaseStatestring
Possible Values
AVAILABLELEASEDEXPIREDBREAKINGBROKEN
leaseStatusstring
Possible Values
LOCKEDUNLOCKED
namestring
ownerstring
permissionsstring
sizeinteger
uristring
Formaturi

The size of the uploaded file, in bytes.

More Plugins in this Category

VMware (EE)
VMware
Enterprise

Tasks that automate VMware vSphere operations within Kestra workflows.

Infrastructure

33 tasks

3 blueprints

Canonical (EE)
Canonical
Enterprise

Tasks to interact with Canonical services, enabling automation and infrastructure management through API-driven workflows.

CloudInfrastructure

5 tasks