airflow.providers.microsoft.azure.triggers.data_factory¶

類¶

`ADFPipelineRunStatusSensorTrigger`	帶有引數的觸發器，用於在 ADF Pipeline 執行時執行任務。
`AzureDataFactoryTrigger`	在 Azure 資料工廠 pipeline 作業完成後觸發。

模組內容¶

class airflow.providers.microsoft.azure.triggers.data_factory.ADFPipelineRunStatusSensorTrigger(run_id, azure_data_factory_conn_id, poke_interval, resource_group_name, factory_name)[原始碼]¶

基類: airflow.triggers.base.BaseTrigger

帶有引數的觸發器，用於在 ADF Pipeline 執行時執行任務。

引數:

run_id (str) – pipeline 執行識別符號。
azure_data_factory_conn_id (str) – 連線 Azure Data Factory 的連線識別符號。
poke_interval (float) – 檢查狀態的輪詢間隔（秒）。
resource_group_name (str) – 資源組名稱。
factory_name (str) – 資料工廠名稱。

run_id[原始碼]¶

azure_data_factory_conn_id[原始碼]¶

resource_group_name[原始碼]¶

factory_name[原始碼]¶

poke_interval[原始碼]¶

serialize()[原始碼]¶

序列化 ADFPipelineRunStatusSensorTrigger 引數和類路徑。

async run()[原始碼]¶

建立與 Azure 資料工廠的非同步連線，輪詢 pipeline 執行狀態。

class airflow.providers.microsoft.azure.triggers.data_factory.AzureDataFactoryTrigger(run_id, azure_data_factory_conn_id, end_time, resource_group_name, factory_name, wait_for_termination=True, check_interval=60)[原始碼]¶