airflow.providers.microsoft.azure.sensors.wasb
¶
Module Contents¶
-
class
airflow.providers.microsoft.azure.sensors.wasb.
WasbBlobSensor
(*, container_name: str, blob_name: str, wasb_conn_id: str = 'wasb_default', check_options: Optional[dict] = None, **kwargs)[source]¶ Bases:
airflow.sensors.base.BaseSensorOperator
Waits for a blob to arrive on Azure Blob Storage.
- Parameters
container_name (str) -- Name of the container.
blob_name (str) -- Name of the blob.
wasb_conn_id (str) -- Reference to the wasb connection.
check_options (dict) -- Optional keyword arguments that WasbHook.check_for_blob() takes.
-
class
airflow.providers.microsoft.azure.sensors.wasb.
WasbPrefixSensor
(*, container_name: str, prefix: str, wasb_conn_id: str = 'wasb_default', check_options: Optional[dict] = None, **kwargs)[source]¶ Bases:
airflow.sensors.base.BaseSensorOperator
Waits for blobs matching a prefix to arrive on Azure Blob Storage.
- Parameters