airflow.providers.informatica.hooks.edc¶

Exceptions¶

InformaticaEDCError

Raised when the Informatica Enterprise Data Catalog API returns an error.

Classes¶

`InformaticaConnectionConfig`	Container for Informatica EDC connection settings.
`InformaticaEDCHook`	Hook providing a minimal client for the Informatica EDC REST API.

Module Contents¶

exception airflow.providers.informatica.hooks.edc.InformaticaEDCError[source]¶

Bases: RuntimeError

Raised when the Informatica Enterprise Data Catalog API returns an error.

class airflow.providers.informatica.hooks.edc.InformaticaConnectionConfig[source]¶

Container for Informatica EDC connection settings.

base_url: str[source]¶

username: str | None[source]¶

password: str | None[source]¶

security_domain: str | None[source]¶

verify_ssl: bool[source]¶

request_timeout: int[source]¶

provider_id: str[source]¶

modified_by: str | None[source]¶

property auth_header: str | None[source]¶

Return the authorization header for the configured credentials.

class airflow.providers.informatica.hooks.edc.InformaticaEDCHook(informatica_edc_conn_id=default_conn_name, *, request_timeout=None, **kwargs)[source]¶

Bases: airflow.providers.http.hooks.http.HttpHook

Hook providing a minimal client for the Informatica EDC REST API.

conn_name_attr = 'informatica_edc_conn_id'[source]¶

default_conn_name[source]¶

conn_type = 'informatica_edc'[source]¶

hook_name = 'Informatica EDC'[source]¶

property config: InformaticaConnectionConfig[source]¶

Return cached connection configuration.

close_session()[source]¶

get_conn(headers=None, extra_options=None)[source]¶

Return a configured session augmented with Informatica specific headers.

get_object(object_id, include_ref_objects=False)[source]¶

Retrieve a catalog object by its identifier.

search_database(database_name)[source]¶

Search for a relational Database or DatabaseServer object by name.

search_schema(schema_name)[source]¶

Search for a relational Schema or DatabaseSchema object by name.

search_table(table_name)[source]¶

Search for a relational Table or View object by name.

create_lineage_link(source_object_id, target_object_id)[source]¶

Create a lineage relationship between source and target objects.