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)[原始碼]

繼承自： 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

serialize()[原始碼]

序列化 WasbBlobSensorTrigger 參數和類別路徑。

async run()[原始碼]

非同步連線到 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)[原始碼]

繼承自： 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) – 檢查狀態的輪詢間隔（秒）

serialize()[原始碼]

序列化 WasbPrefixSensorTrigger 參數和類別路徑。

async run()[原始碼]

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

這個條目有幫助嗎？