astronomer.providers.microsoft.azure.hooks.data_factory
¶
Module Contents¶
Classes¶
An Async Hook connects to Azure DataFactory to perform pipeline operations |
Functions¶
Provide the targeted factory to the async decorated function in case it isn't specified. |
Attributes¶
- astronomer.providers.microsoft.azure.hooks.data_factory.Credentials¶
- astronomer.providers.microsoft.azure.hooks.data_factory.T¶
- astronomer.providers.microsoft.azure.hooks.data_factory.provide_targeted_factory_async(func)[source]¶
Provide the targeted factory to the async decorated function in case it isn’t specified.
If
resource_group_name
orfactory_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)[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_pipeline_run(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(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.