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]¶