airflow.providers.openlineage.extractors.manager¶

类¶

抽象管理自定义提取器的类。

class airflow.providers.openlineage.extractors.manager.ExtractorManager[源代码]¶

基类: airflow.utils.log.logging_mixin.LoggingMixin

抽象管理自定义提取器的类。

extractors: dict[str, type[airflow.providers.openlineage.extractors.BaseExtractor]][源代码]¶

add_extractor(operator_class, extractor)[源代码]¶

extract_metadata(dagrun, task, task_instance_state, task_instance=None)[源代码]¶

get_extractor_class(task)[源代码]¶

extract_inlets_and_outlets(task_metadata, task)[源代码]¶

get_hook_lineage()[源代码]¶

static convert_to_ol_dataset_from_object_storage_uri(uri)[源代码]¶

static convert_to_ol_dataset_from_table(table)[源代码]¶

static convert_to_ol_dataset(obj)[源代码]¶

validate_task_metadata(task_metadata)[源代码]¶