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

模組內容¶

類別¶

`ADFPipelineRunStatusSensorTrigger`	當 ADF 管線正在執行時，使用參數觸發任務。
`AzureDataFactoryTrigger`	當 Azure Data Factory 管線工作完成時觸發。

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 管線正在執行時，使用參數觸發任務。

參數

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

serialize()[原始碼]¶

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

async run()[原始碼]¶

非同步連線至 Azure Data Factory，輪詢管線執行狀態。

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

基底類別: airflow.triggers.base.BaseTrigger

當 Azure Data Factory 管線工作完成時觸發。

當 wait_for_termination 設定為 False 時，會立即以成功狀態觸發。