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