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

模块内容¶

类¶

`ADFPipelineRunStatusSensorTrigger`	当 ADF 管道正在运行时，使用参数运行任务的触发器。
`AzureDataFactoryTrigger`	当 Azure 数据工厂管道作业完成时触发的触发器。

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

基类: airflow.triggers.base.BaseTrigger

当 ADF 管道正在运行时，使用参数运行任务的触发器。

参数

run_id (str) – 管道运行标识符。
azure_data_factory_conn_id (str) – 用于连接到 Azure 数据工厂的连接标识符。
poke_interval (float) – 检查状态的轮询间隔（秒）。
resource_group_name (str) – 资源组名称。
factory_name (str) – 数据工厂名称。

serialize()[source]¶

序列化 ADFPipelineRunStatusSensorTrigger 参数和类路径。

async run()[source]¶

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

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

基类: airflow.triggers.base.BaseTrigger

当 Azure 数据工厂管道作业完成时触发的触发器。

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