`astronomer.providers.microsoft.azure.hooks.data_factory`¶

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

Module Contents¶

An Async Hook connects to Azure DataFactory to perform pipeline operations.

`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.

`Credentials`
`T`

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

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

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

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

Get async connection and connect to azure data factory.

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

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

Parameters:

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

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

Parameters: