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)[源码]¶

基类: airflow.triggers.base.BaseTrigger

在 Azure 数据工厂 pipeline 作业完成后触发。

当 wait_for_termination 设置为 False 时，它会立即以成功状态触发。

参数:

run_id (str) – Azure 数据 pipeline 运行作业的运行 ID。
azure_data_factory_conn_id (str) – 连接 Azure Data Factory 的连接标识符。
end_time (float) – 触发器将超时的秒数。
resource_group_name (str) – 资源组名称。
factory_name (str) – 数据工厂名称。
wait_for_termination (bool) – 等待 pipeline 运行终止的标志。
check_interval (int) – 检查 pipeline 运行状态的秒数。

azure_data_factory_conn_id[源码]¶

check_interval = 60[源码]¶

run_id[源码]¶

wait_for_termination = True[源码]¶

resource_group_name[源码]¶

factory_name[源码]¶

end_time[源码]¶

serialize()[源码]¶

序列化 AzureDataFactoryTrigger 参数和类路径。

async run()[源码]¶

建立与 Azure 数据工厂的异步连接，轮询 pipeline 运行状态。