WasbPrefixSensorAsync

Astronomer Providers

Polls asynchronously for the existence of a blob having the given prefix in a WASB 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_nameRequiredname of the container in which the blob should be searched for
blob_namename 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
poll_intervalpolling period in seconds to check for the status
public_readwhether an anonymous public read access should be used. Default is False

Documentation

Polls asynchronously for the existence of a blob having the given prefix in a WASB container.

Was this page helpful?