Azure DataLake Storage Operators

Prerequisite Tasks

AzureDataLakeStorageDeleteOperator

Use the AzureDataLakeStorageDeleteOperator to remove file(s) from Azure DataLake Storage

Below is an example of using this operator to delete a file from ADL.

airflow/providers/microsoft/azure/example_dags/example_adls_delete.pyView Source

    remove_file = AzureDataLakeStorageDeleteOperator(
        task_id="delete_task", path=REMOTE_FILE_PATH, recursive=True
    )

Reference

For further information, look at:

Was this entry helpful?