`airflow.providers.openlineage.extractors.manager`¶

模块内容¶

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

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

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

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

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

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

get_extractor_class(task)[源代码]¶

extract_inlets_and_outlets(task_metadata, inlets, outlets)[源代码]¶

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)[源代码]¶