airflow.providers.microsoft.azure.triggers.wasb¶

類¶

`WasbBlobSensorTrigger`	檢查給定 Blob 在提供的容器中是否存在。
`WasbPrefixSensorTrigger`	檢查具有給定字首的 Blob 在提供的容器中是否存在。

模組內容¶

class airflow.providers.microsoft.azure.triggers.wasb.WasbBlobSensorTrigger(container_name, blob_name, wasb_conn_id='wasb_default', public_read=False, poke_interval=5.0)[source]¶

基類: airflow.triggers.base.BaseTrigger

檢查給定 Blob 在提供的容器中是否存在。

WasbBlobSensorTrigger 作為延遲類觸發，帶有引數以在觸發器工作程序中執行任務。

引數:

container_name (str) – 應搜尋 Blob 的容器名稱
blob_name (str) – 要檢查是否存在的 Blob 名稱
wasb_conn_id (str) – 連線到 Azure WASB 的連線識別符號
poke_interval (float) – 檢查狀態的輪詢間隔（秒）
public_read (bool) – 是否應使用匿名公共讀訪問。預設為 False

container_name[source]¶

blob_name[source]¶

wasb_conn_id = 'wasb_default'[source]¶

poke_interval = 5.0[source]¶

public_read = False[source]¶

serialize()[source]¶

序列化 WasbBlobSensorTrigger 引數和類路徑。

async run()[source]¶

非同步連線到 Azure WASB 並輪詢給定 Blob 名稱是否存在。

class airflow.providers.microsoft.azure.triggers.wasb.WasbPrefixSensorTrigger(container_name, prefix, wasb_conn_id='wasb_default', check_options=None, public_read=False, poke_interval=5.0)[source]¶

基類: airflow.triggers.base.BaseTrigger

檢查具有給定字首的 Blob 在提供的容器中是否存在。

WasbPrefixSensorTrigger 作為延遲類觸發，帶有引數以在觸發器工作程序中執行任務。

引數:

container_name (str) – 應搜尋 Blob 的容器名稱
prefix (str) – 要檢查是否存在的 Blob 字首
include – 指定要包含在響應中的一個或多個附加資料集。選項包括：snapshots, metadata, uncommittedblobs, copy, deleted
delimiter – 基於分隔符過濾物件（例如 '.csv'）
wasb_conn_id (str) – 連線到 Azure WASB 的連線識別符號
check_options (dict | None) – WasbAsyncHook.check_for_prefix_async() 方法接受的可選關鍵字引數。
public_read (bool) – 是否應使用匿名公共讀訪問。預設為 False
poke_interval (float) – 檢查狀態的輪詢間隔（秒）

container_name[source]¶

prefix[source]¶

wasb_conn_id = 'wasb_default'[source]¶

check_options = None[source]¶

poke_interval = 5.0[source]¶

public_read = False[source]¶

serialize()[source]¶

序列化 WasbPrefixSensorTrigger 引數和類路徑。

async run()[source]¶

非同步連線到 Azure WASB 並輪詢具有給定字首的 Blob 是否存在。