DeleteFiles DeleteFiles

yaml
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

yaml
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?