WasbPrefixSensorTrigger
Astronomer ProvidersWasbPrefixSensorTrigger is fired as a deferred class with params to run the task in trigger worker. It checks for the existence of a blob with the given prefix in the provided container.
Access Instructions
Install the Astronomer Providers provider package into your Airflow environment.
Import the module into your DAG file and instantiate it with your desired params.
Parameters
container_namename of the container in which the blob should be searched for
prefixprefix of the blob to check existence for
includespecifies one or more additional datasets to include in the response. Options include: snapshots, metadata, uncommittedblobs, copy`, ``deleted
delimiterfilters objects based on the delimiter (for e.g ‘.csv’)
wasb_conn_idthe connection identifier for connecting to Azure WASB
poke_intervalpolling period in seconds to check for the status
public_readwhether an anonymous public read access should be used. Default is False
Documentation
WasbPrefixSensorTrigger is fired as a deferred class with params to run the task in trigger worker. It checks for the existence of a blob with the given prefix in the provided container.