airflow.providers.openlineage.extractors.python¶

類¶

提取執行的原始碼並將其放入 SourceCodeJobFacet 中。

class airflow.providers.openlineage.extractors.python.PythonExtractor(operator)[source]¶

提取執行的原始碼並將其放入 SourceCodeJobFacet 中。

該提取器透過提取執行的原始碼並將其放入 SourceCodeJobFacet 中，提供了關於特定任務所做內容的可見性。它尚不提取資料集。

classmethod get_operator_classnames()[source]¶

獲取該提取器適用的操作器列表。

這是一個抽象方法，子類應實現它。有些操作器工作方式非常相似，一個提取器即可覆蓋。

get_source_code(callable)[source]¶

extract()[source]¶