DeleteFiles
DeleteFiles
type: "io.kestra.plugin.azure.storage.adls.DeleteFiles"
Delete a list of keys from the Azure Data Lake Storage.
Examples
Download files from a remote server, upload them to Azure Data Lake Storage, finally delete them all at one
id: azure_storage_blob_delete_list
namespace: company.team
pluginDefaults:
- type: io.kestra.plugin.azure.storage.adls
values:
connectionString: "{{ secret('AZURE_CONNECTION_STRING') }}"
fileSystem: "tasks"
endpoint: "https://yourblob.blob.core.windows.net"
tasks:
- id: for_each
type: io.kestra.plugin.core.flow.EachSequential
value: ["pikachu", "charmander"]
tasks:
- id: download_request
type: io.kestra.plugin.core.http.Download
uri: https://pokeapi.co/api/v2/pokemon/{{ taskrun.value }}
- id: to_ion
type: io.kestra.plugin.serdes.json.JsonToIon
from: "{{ currentEachOutput(outputs.download_request).uri }}"
- id: upload_file
type: io.kestra.plugin.azure.storage.adls.Upload
fileName: "adls/pokemon/{{ taskrun.value }}.json"
from: "{{ currentEachOutput(outputs.to_ion).uri }}"
- id: delete_file
type: io.kestra.plugin.azure.storage.adls.DeleteFiles
concurrent: 2
directoryPath: "adls/pokemon/"
Properties
directoryPath
- Type: string
- Dynamic: ✔️
- Required: ✔️
Directory Name
endpoint
- Type: string
- Dynamic: ✔️
- Required: ✔️
The blob service endpoint.
fileSystem
- Type: string
- Dynamic: ✔️
- Required: ✔️
The name of the file systems. If the path name contains special characters, pass in the url encoded version of the path name.
concurrent
- Type: integer
- Dynamic: ❌
- Required: ❌
- Minimum:
>= 2
Number of concurrent parallel deletions.
connectionString
- Type: string
- Dynamic: ✔️
- Required: ❌
Connection string of the Storage Account.
errorOnEmpty
- Type: boolean
- Dynamic: ✔️
- Required: ❌
- Default:
false
Whether to raise an error if the file is not found.
sasToken
- Type: string
- Dynamic: ✔️
- Required: ❌
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.
sharedKeyAccountAccessKey
- Type: string
- Dynamic: ✔️
- Required: ❌
Shared Key access key for authenticating requests.
sharedKeyAccountName
- Type: string
- Dynamic: ✔️
- Required: ❌
Shared Key account name for authenticating requests.
Outputs
count
- Type: integer
- Required: ❌
- Default:
0
The count of deleted files.
size
- Type: integer
- Required: ❌
- Default:
0
The size of all the deleted files.
Was this page helpful?