`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 巨集