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()[source]¶: 宏函数，返回 Airflow OpenLineage 命名空间。

另请参阅

更多信息请参阅指南：OpenLineage 宏

airflow.providers.openlineage.plugins.macros.lineage_job_name(task_instance)[source]¶

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

另请参阅

更多信息请参阅指南：OpenLineage 宏

airflow.providers.openlineage.plugins.macros.lineage_run_id(task_instance)[source]¶

宏函数，返回给定任务生成的运行 ID (UUID)。

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

另请参阅

更多信息请参阅指南：OpenLineage 宏

airflow.providers.openlineage.plugins.macros.lineage_parent_id(task_instance)[source]¶

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

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

另请参阅

更多信息请参阅指南：OpenLineage 宏