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

模块内容¶

类¶

`WasbBlobSensor`	等待 Azure Blob 存储上的 Blob 到达。
`WasbPrefixSensor`	等待 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 到达。

参数

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]¶

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]¶