astronomer.providers.microsoft.azure.hooks.data_factory

This module contains the Azure Data Factory hook’s asynchronous implementation.

Attributes

Credentials
T

Classes

AzureDataFactoryHookAsync

This class is deprecated and will be removed in 2.0.0.

Functions

get_field(extras, field_name[, strict])	Get field from extra, first checking short name, then for backward compatibility we check for prefixed name.
provide_targeted_factory_async(func)	Provide the targeted factory to the async decorated function in case it isn't specified.

Module Contents

astronomer.providers.microsoft.azure.hooks.data_factory.Credentials

astronomer.providers.microsoft.azure.hooks.data_factory.T

astronomer.providers.microsoft.azure.hooks.data_factory.get_field(extras, field_name, strict=False)

Get field from extra, first checking short name, then for backward compatibility we check for prefixed name.

astronomer.providers.microsoft.azure.hooks.data_factory.provide_targeted_factory_async(func)

Provide the targeted factory to the async decorated function in case it isn’t specified.

If resource_group_name or factory_name is not provided it defaults to the value specified in the connection extras.

class astronomer.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHookAsync(azure_data_factory_conn_id)

Bases: airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook

This class is deprecated and will be removed in 2.0.0. Use :class: ~airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook instead.

conn_id

async get_async_conn()

Get async connection and connect to azure data factory.

async get_pipeline_run(run_id, resource_group_name, factory_name, **config)

Connect to Azure Data Factory asynchronously to get the pipeline run details by run id.

Parameters:

• run_id (str) – The pipeline run identifier.

• resource_group_name (str) – The resource group name.

• factory_name (str) – The factory name.

async get_adf_pipeline_run_status(run_id, resource_group_name, factory_name)

Connect to Azure Data Factory asynchronously and get the pipeline status by run_id.

Parameters:

• run_id (str) – The pipeline run identifier.

• resource_group_name (str) – The resource group name.

• factory_name (str) – The factory name.