WASB Blob Sensor Async¶
To poll asynchronously for the existence of a blob in a WASB container.
WasbBlobSensorAsync
.
wasb_blob_sensor = WasbBlobSensorAsync(
task_id="wasb_blob_sensor",
container_name=AZURE_DATA_STORAGE_CONTAINER_NAME,
blob_name=AZURE_DATA_STORAGE_BLOB_NAME,
wasb_conn_id=AZURE_WASB_CONN_ID,
)
# https://github.com/astronomer/astronomer-providers/tree/main/astronomer/providers/microsoft/azure/example_dags/example_wasb_sensors.py
To poll asynchronously for the existence of a blob having the given prefix in a WASB container
WasbPrefixSensorAsync
.
wasb_prefix_sensor = WasbPrefixSensorAsync(
task_id="wasb_prefix_sensor",
container_name=AZURE_DATA_STORAGE_CONTAINER_NAME,
prefix=AZURE_DATA_STORAGE_BLOB_NAME[:10],
wasb_conn_id=AZURE_WASB_CONN_ID,
)
# https://github.com/astronomer/astronomer-providers/tree/main/astronomer/providers/microsoft/azure/example_dags/example_wasb_sensors.py