Upload
Upload a file to Azure Blob Storage container.
type: "io.kestra.plugin.azure.storage.blob.Upload"
Examples
Upload an input file to Azure Blob Storage
id: azure_storage_blob_upload
namespace: company.team
inputs:
- id: myfile
type: FILE
tasks:
- id: upload
type: io.kestra.plugin.azure.storage.blob.Upload
endpoint: https://kestra.blob.core.windows.net
connectionString: "{{ secret('AZURE_CONNECTION_STRING') }}"
container: kestra
from: "{{ inputs.myfile }}"
name: "myblob"
Extract data via an HTTP API call and upload it as a file to Azure Blob Storage
id: azure_blob_upload
namespace: company.team
tasks:
- id: extract
type: io.kestra.plugin.core.http.Download
uri: https://huggingface.co/datasets/kestra/datasets/raw/main/csv/salaries.csv
- id: load
type: io.kestra.plugin.azure.storage.blob.Upload
endpoint: https://kestra.blob.core.windows.net
connectionString: "{{ secret('AZURE_CONNECTION_STRING') }}"
container: kestra
from: "{{ outputs.extract.uri }}"
name: data.csv
Properties
container *Requiredstring
The blob container.
endpoint *Requiredstring
The blob service endpoint.
from *Requiredstring
The file from the internal storage to upload to the Azure Blob Storage.
Pebble expression referencing an Internal Storage URI e.g. {{ outputs.mytask.uri }}
.
name *Requiredstring
The full blob path on the container.
accessTier string
P4
P6
P10
P15
P20
P30
P40
P50
P60
P70
P80
HOT
COOL
ARCHIVE
The access tier of the uploaded blob.
The operation is allowed on a page blob in a premium Storage Account or a block blob in a blob Storage Account or GPV2 Account. A premium page blob's tier determines the allowed size, IOPS, and bandwidth of the blob. A block blob's tier determines the Hot/Cool/Archive storage type. This does not update the blob's etag.
connectionString string
Connection string of the Storage Account.
immutabilityPolicy Non-dynamicBlobImmutabilityPolicy
legalHold booleanstring
Sets a legal hold on the blob.
NOTE: Blob Versioning must be enabled on your storage account and the blob must be in a container with immutable storage with versioning enabled to call this API.
metadata object
Metadata for the blob.
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
blob Blob
The uploaded blob.
Definitions
io.kestra.plugin.azure.storage.blob.models.BlobImmutabilityPolicy
expiryTime string
date-time
The time when the immutability policy expires.
policyMode string
MUTABLE
UNLOCKED
LOCKED
The immutability policy mode.
io.kestra.plugin.azure.storage.blob.models.Blob
container string
name string
size integer
uri string
uri