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

模組內容¶

類別¶

`WasbBlobSensor`	等待 Blob 抵達 Azure Blob 儲存體。
`WasbPrefixSensor`	等待符合前綴的 Blob 抵達 Azure 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

等待 Blob 抵達 Azure 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]¶