Upload
Upload a file to the Azure Blob Storage.
type: "io.kestra.plugin.azure.storage.blob.Upload"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
The blob container.
The blob service endpoint.
The full blob path on the container.
P4P6P10P15P20P30P40P50P60P70P80HOTCOOLARCHIVEThe 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.
Connection string of the Storage Account.
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 }}.
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 for the blob.
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.
The uploaded blob.
date-timeThe time when the immutability policy expires.
MUTABLEUNLOCKEDLOCKEDThe immutability policy mode.
uri