airflow.providers.microsoft.azure.sensors.wasb
¶
模块内容¶
类¶
等待 Azure Blob 存储上的 Blob 到达。 |
|
等待 Azure Blob 存储上与前缀匹配的 Blob 到达。 |
- class airflow.providers.microsoft.azure.sensors.wasb.WasbBlobSensor(*, container_name, blob_name, wasb_conn_id='wasb_default', check_options=None, public_read=False, deferrable=conf.getboolean('operators', 'default_deferrable', fallback=False), **kwargs)[source]¶
基类:
airflow.sensors.base.BaseSensorOperator
等待 Azure Blob 存储上的 Blob 到达。
- 参数
- template_fields: collections.abc.Sequence[str] = ('container_name', 'blob_name')[source]¶
- class airflow.providers.microsoft.azure.sensors.wasb.WasbPrefixSensor(*, container_name, prefix, wasb_conn_id='wasb_default', check_options=None, public_read=False, deferrable=conf.getboolean('operators', 'default_deferrable', fallback=False), **kwargs)[source]¶
基类:
airflow.sensors.base.BaseSensorOperator
等待 Azure Blob 存储上与前缀匹配的 Blob 到达。
- 参数
- template_fields: collections.abc.Sequence[str] = ('container_name', 'prefix')[source]¶