airflow.providers.microsoft.azure.sensors.wasb¶

类¶

`WasbBlobSensor`	等待 Blob 到达 Azure Blob Storage。
`WasbPrefixSensor`	等待与前缀匹配的 Blob 到达 Azure Blob Storage。

模块内容¶

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

等待 Blob 到达 Azure Blob Storage。

参数:

container_name (str) – 容器名称。
blob_name (str) – Blob 名称。
wasb_conn_id (str) – 引用 wasb 连接。
check_options (dict | None) – WasbHook.check_for_blob() 接受的可选关键字参数。
deferrable (bool) – 以可推迟模式运行传感器。
public_read (bool) – 是否应使用匿名公共读取访问权限。默认值为 False

template_fields: collections.abc.Sequence[str] = ('container_name', 'blob_name')[source]¶

wasb_conn_id = 'wasb_default'[source]¶

container_name[source]¶

blob_name[source]¶

check_options = None[source]¶

public_read = False[source]¶

deferrable = True[source]¶

poke(context)[source]¶

派生此类时重写此方法。

execute(context)[source]¶

轮询作业运行状态。

在可推迟模式下，轮询被推迟到触发器。否则，传感器同步等待。

execute_complete(context, event)[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]¶