airflow.providers.openlineage.extractors.bash

BashExtractor

提取执行的 Bash 命令并将其放入 SourceCodeJobFacet。

模块内容

class airflow.providers.openlineage.extractors.bash.BashExtractor(operator)[source]

Bases: airflow.providers.openlineage.extractors.base.BaseExtractor

提取执行的 Bash 命令并将其放入 SourceCodeJobFacet。

此提取器通过提取执行的 Bash 命令并将其放入 SourceCodeJobFacet,提供对 Bash 任务执行情况的可视化。它不提取数据集。

classmethod get_operator_classnames()[source]

获取提取器适用的运算符列表。

这是一个抽象方法,子类应实现它。有些运算符的工作方式非常相似,一个提取器即可覆盖。

extract()[source]

此条目是否有帮助?