`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)[原始碼]¶