`airflow.providers.openlineage.plugins.macros`¶

模块内容¶

`lineage_job_namespace`()	返回 Airflow OpenLineage 命名空间的宏函数。
`lineage_job_name`(task_instance)	返回 OpenLineage 格式的 Airflow 任务名称（<dag_id>.<task_id>）的宏函数。
`lineage_run_id`(task_instance)	返回给定任务生成的运行 ID（UUID）的宏函数。
`lineage_parent_id`(task_instance)	返回给定任务的唯一标识符的宏函数，该标识符可用于创建 ParentRunFacet。

airflow.providers.openlineage.plugins.macros.lineage_job_namespace()[源代码]¶: 返回 Airflow OpenLineage 命名空间的宏函数。

另请参阅

有关详细信息，请查看指南：OpenLineage 宏

airflow.providers.openlineage.plugins.macros.lineage_job_name(task_instance)[源代码]¶

返回 OpenLineage 格式的 Airflow 任务名称（<dag_id>.<task_id>）的宏函数。

另请参阅

有关详细信息，请查看指南：OpenLineage 宏

airflow.providers.openlineage.plugins.macros.lineage_run_id(task_instance)[源代码]¶

返回给定任务生成的运行 ID（UUID）的宏函数。

这可用于将运行 ID 从任务转发到子运行，以便保留作业层次结构。

另请参阅

有关详细信息，请查看指南：OpenLineage 宏

airflow.providers.openlineage.plugins.macros.lineage_parent_id(task_instance)[源代码]¶

返回给定任务的唯一标识符的宏函数，该标识符可用于创建 ParentRunFacet。

此标识符由给定任务的命名空间、作业名称和生成的运行 ID 组成，结构为“{namespace}/{job_name}/{run_id}”。这可用于将任务信息从任务转发到子运行，以便保留作业层次结构。子运行可以很容易地从这些信息创建 ParentRunFacet。

另请参阅

有关详细信息，请查看指南：OpenLineage 宏