WasbPrefixSensor
Microsoft AzureWaits for blobs matching a prefix to arrive on Azure Blob Storage.
Access Instructions
Install the Microsoft Azure provider package into your Airflow environment.
Import the module into your DAG file and instantiate it with your desired params.
Parameters
container_nameRequiredName of the container.
prefixRequiredPrefix of the blob.
wasb_conn_idReference to the wasb connection.
check_optionsOptional keyword arguments that WasbHook.check_for_prefix() takes.
Documentation
Waits for blobs matching a prefix to arrive on Azure Blob Storage.