astronomer.providers.microsoft.azure.hooks.data_factory

Module Contents

Classes

AzureDataFactoryHookAsync

An Async Hook connects to Azure DataFactory to perform pipeline operations

Attributes

Credentials

astronomer.providers.microsoft.azure.hooks.data_factory.Credentials
class astronomer.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHookAsync(azure_data_factory_conn_id)[source]

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

An Async Hook connects to Azure DataFactory to perform pipeline operations

Parameters

azure_data_factory_conn_id (str) – The Azure Data Factory connection id.

async get_async_conn(self)[source]

Get async connection and connect to azure data factory

async get_pipeline_run(self, run_id, resource_group_name=None, factory_name=None, **config)[source]

Connects 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 (Optional[str]) – The resource group name.

  • factory_name (Optional[str]) – The factory name.

async get_adf_pipeline_run_status(self, run_id, resource_group_name=None, factory_name=None)[source]

Connects to Azure Data Factory asynchronously and gets the pipeline status by run_id

Parameters

  • run_id (str) – The pipeline run identifier.

  • resource_group_name (Optional[str]) – The resource group name.

  • factory_name (Optional[str]) – The factory name.