Azure DataLake Storage Operators

Prerequisite Tasks

ADLSDeleteOperator

Use the ADLSDeleteOperator 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 = ADLSDeleteOperator(task_id="delete_task", path=REMOTE_FILE_PATH, recursive=True)

Reference

For further information, look at:

Was this entry helpful?