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