共用方式為


譜系系統數據表參考

重要

此系統數據表位於公開預覽版 。 若要存取資料表,必須在您的 system 目錄中啟用架構。 如需詳細資訊,請參閱 啟用系統資料表架構

本文提供這兩個譜系系統數據表的概觀。 這些系統數據表建置在 Unity Catalog 數據譜系功能,可讓您以程式設計方式查詢譜系數據,以推動決策和報告。

注意

這兩個譜系數據表都代表所有讀取/寫入事件的子集,因為擷取譜系並不總是可能的。 只有在可推斷譜系時,才會發出記錄。

表譜系

表格血緣系統表包含每個在 Unity Catalog 表格或路徑上進行的讀取或寫入事件的記錄。 這包括但不限於作業執行、筆記本執行,以及使用讀取或寫入事件更新的儀表板。

資料表路徑:此系統資料表位於 system.access.table_lineage

數據表譜系架構

譜系系統的數據表使用以下模式。

欄位名稱 資料類型 描述 範例
account_id 字串 Azure Databricks 帳戶的識別碼。 7af234db-66d7-4db3-bbf0-956098224879
metastore_id 字串 Unity 目錄中繼存放區的標識碼。 5a31ba44-bbf4-4174-bf33-e1fa078e6765
workspace_id 字串 工作區的識別碼 123456789012345
entity_type 字串 從中擷取譜系交易的實體類型。 值為 NOTEBOOKJOBPIPELINEDASHBOARD_V3 (儀表板)、DBSQL_DASHBOARD (舊版儀表板)、DBSQL_QUERYNULL NOTEBOOK
entity_id 字串 從中擷取譜系交易之實體的識別碼。 如果 entity_typeNULL,則 entity_idNULL - 筆記本:23098402394234
- 作業:23098402394234
- Databricks SQL 查詢:e9cd8a31-de2f-4206-adfa-4f6605d68d88
- 儀表板:01ef070d110715f2b6d3061b8bda89ea
- 舊版儀表板:e9cd8a31-de2f-4206-adfa-4f6605d68d88
- 管線:e9cd8a31-de2f-4206-adfa-4f6605d68d88
entity_run_id 字串 描述實體的唯一執行識別碼,或 NULL。 每種實體類型都有所不同:

- 筆記本:command_run_id
- 作業:job_run_id
- Databricks SQL 查詢:query_run_id
- 儀表板:query_run_id
- 舊版儀表板:query_run_id
- 管線:pipeline_update_id

如果 entity_typeNULL,則 entity_run_idNULL
- 筆記本:e3cr5a10-de6f-6206-fdfa-4f5505d68d55
- 作業:51090402394234
- Databricks SQL 查詢:e9cd8a31-de2f-4206-adfa-4f6605d68d88
- 儀表板:c3ra5m10-pt6o-6206-mdfa-4f5505d68d55
- 舊版儀表板:c3ra5m10-pt6o-6206-mdfa-4f5505d68d55
- 管線:c5am1e0r-on2f-4206-adfa-4f6605d68d88
source_table_full_name 字串 識別來源資料表的三段式名稱。 catalog.schema.table
source_table_catalog 字串 源數據表的目錄。 catalog
source_table_schema 字串 源數據表的架構。 schema
source_table_name 字串 源數據表的名稱。 table
source_path 字串 源數據表雲端記憶體中的位置,或直接從雲端記憶體讀取路徑。 abfss://my-container-name@storage-account-name.dfs.core.windows.net/table1
source_type 字串 來源的類型。 該值為 TABLEPATHVIEWSTREAMING_TABLE TABLE
target_table_full_name 字串 三部分名稱來識別目標資料表。 catalog.schema.table
target_table_catalog 字串 目標資料表的目錄。 catalog
target_table_schema 字串 目標資料表的結構。 schema
target_table_name 字串 目標資料表的名稱。 table
target_path 字串 目標數據表雲端記憶體中的位置。 abfss://my-container-name@storage-account-name.dfs.core.windows.net/table1
target_type 字串 目標的類型。 該值為 TABLEPATHVIEWSTREAMING TABLE TABLE
created_by 字串 產生此譜系的使用者。 這可以是 Azure Databricks 使用者名稱、Azure Databricks 服務主體識別碼「System-User」,或 NULL (無法擷取使用者資訊)。 crampton.rods@email.com
event_time timestamp 產生譜系時的時間戳記。 時區資訊會記錄在值結尾,+00:00 表示 UTC。 2023-06-20T19:47:21.194+00:00
event_date date 產生譜系的日期。 這是分區的欄位。 2023-06-20

數據行譜數據表

欄位血緣表不包含沒有來源的事件。 例如,如果您使用明確值插入資料欄,則不會擷取它。 當您讀取某個欄位時,無論您是否寫入輸出,它都會被擷取。 Delta Live Tables 不支持欄位譜系。

資料表路徑:此系統資料表位於 system.access.column_lineage

欄位譜系架構

欄位譜系系統資料表會使用下列架構:

欄位名稱 資料類型 描述 範例
account_id 字串 Azure Databricks 帳戶的識別碼。 7af234db-66d7-4db3-bbf0-956098224879
metastore_id 字串 Unity 目錄中繼存放區的標識碼。 5a31ba44-bbf4-4174-bf33-e1fa078e6765
workspace_id 字串 工作區的識別碼 123456789012345
entity_type 字串 從中擷取譜系交易的實體類型。 值為 NOTEBOOKJOBPIPELINEDASHBOARD_V3 (儀表板)、DBSQL_DASHBOARD (舊版儀表板)、DBSQL_QUERYNULL NOTEBOOK
entity_id 字串 從中擷取譜系交易之實體的識別碼。 如果 entity_typeNULL,則 entity_idNULL - 筆記本:23098402394234
- 作業:23098402394234
- Databricks SQL 查詢:e9cd8a31-de2f-4206-adfa-4f6605d68d88
- 儀表板:01ef070d110715f2b6d3061b8bda89ea
- 舊版儀表板:e9cd8a31-de2f-4206-adfa-4f6605d68d88
- 管線:e9cd8a31-de2f-4206-adfa-4f6605d68d88
entity_run_id 字串 描述實體的唯一執行識別碼,或 NULL。 每種實體類型都有所不同:

- 筆記本:command_run_id
- 作業:job_run_id
- Databricks SQL 查詢:query_run_id
- 儀表板:query_run_id
- 舊版儀表板:query_run_id
- 管線:pipeline_update_id

如果 entity_typeNULL,則 entity_run_idNULL
- 筆記本:e3cr5a10-de6f-6206-fdfa-4f5505d68d55
- 作業:51090402394234
- Databricks SQL 查詢:e9cd8a31-de2f-4206-adfa-4f6605d68d88
- 儀表板:c3ra5m10-pt6o-6206-mdfa-4f5505d68d55
- 舊版儀表板:c3ra5m10-pt6o-6206-mdfa-4f5505d68d55
- 管線:c5am1e0r-on2f-4206-adfa-4f6605d68d88
source_table_full_name 字串 識別來源資料表的三段式名稱。 catalog.schema.table
source_table_catalog 字串 源數據表的目錄。 catalog
source_table_schema 字串 源數據表的架構。 schema
source_table_name 字串 源數據表的名稱。 table
source_path 字串 源數據表雲端記憶體中的位置,或直接從雲端記憶體讀取路徑。 abfss://my-container-name@storage-account-name.dfs.core.windows.net/table1
source_type 字串 來源的類型。 該值為 TABLEPATHVIEWSTREAMING_TABLE TABLE
source_column_name 字串 來源欄的名稱。 date
target_table_full_name 字串 三部分名稱來識別目標資料表。 catalog.schema.table
target_table_catalog 字串 目標資料表的目錄。 catalog
target_table_schema 字串 目標資料表的結構。 schema
target_table_name 字串 目標資料表的名稱。 table
target_path 字串 目標數據表雲端記憶體中的位置。 abfss://my-container-name@storage-account-name.dfs.core.windows.net/table1
target_type 字串 目標的類型。 該值為 TABLEPATHVIEWSTREAMING TABLE TABLE
target_column_name 字串 目標欄的名稱。 date
created_by 字串 產生此譜系的使用者。 這可以是 Azure Databricks 使用者名稱、Azure Databricks 服務主體識別碼「System-User」,或 NULL (無法擷取使用者資訊)。 crampton.rods@email.com
event_time timestamp 產生譜系時的時間戳記。 時區資訊會記錄在值結尾,+00:00 表示 UTC。 2023-06-20T19:47:21.194+00:00
event_date date 產生譜系的日期。 這是分區的欄位。 2023-06-20

讀取譜系系統數據表

在分析譜系系統數據表時,請注意下列考慮:

  • 針對 entity_type,Azure Databricks 支援 Delta Live Tables、筆記本、工作、Databricks SQL 查詢和儀表板。 不支援來自其他實體的事件。
  • 如果您將 entity_type 視為 null,表示事件中未涉及任何 Azure Databricks 實體。 例如,可能是 JDBC 查詢的結果,或使用者按下 Azure Databricks UI 中的 [範例資料] 索引標籤。
  • 若要判斷事件是讀取還是寫入,可檢視來源類型和目標類型。
    • 唯讀:來源類型並非 Null,但目標類型為 Null。
    • 唯寫:目標類型並非 Null,但來源類型為 Null。
    • 讀取和寫入:來源類型和目標類型都不是 Null。

譜系系統數據表範例

作為系統數據表中記錄數據譜系的範例,以下是一個查詢範例,接下來是該查詢所建立的譜系記錄:

CREATE OR REPLACE TABLE car_features
AS SELECT *,  in1+in2 as premium_feature_set
FROM car_features_exterior
JOIN car_features_interior
USING(id, model);

system.access.table_lineage 中的記錄看起來就像:

entity_type entity_id source_table_name target_table_name created_by event_time
NOTEBOOK 27080565267 car_features_exterior car_features crampton@email.com 2023-01-25T16:19:58.908+0000
NOTEBOOK 27080565267 car_features_interior car_features crampton@email.com 2023-01-25T16:19:58.908+0000

system.access.column_lineage 中的記錄看起來就像:

entity_type entity_id source_table_name target_table_name source_column_name target_column_name event_time
NOTEBOOK 27080565267 car_features_interior car_features in1 premium_feature_set 2023-01-25T16:19:58.908+0000
NOTEBOOK 27080565267 car_features_interior car_features in2 premium_feature_set 2023-01-25T16:19:58.908+0000

注意

上述範例中未顯示所有的譜系欄位。 如需完整的架構,請參閱上述 譜系架構

針對外部數據表查詢進行疑難解答

當您使用外部數據表的雲端記憶體路徑來參考外部數據表時,相關聯的歷程記錄只會包含路徑名稱,而不是數據表名稱。 例如,此查詢的歷程記錄會包含路徑名稱,而不是資料表名稱:

SELECT * FROM delta.`abfss://my-container-name@storage-account-name.dfs.core.windows.net/table1`;

如果您試著查詢路徑所參考之外部資料表的歷程記錄,則必須使用 source_pathtarget_path 來篩選查詢,而不是使用 source_table_full_nametarget_table_full_name。 例如,下列查詢會提取外部數據表的所有歷程記錄:

SELECT *
FROM system.access.table_lineage
WHERE
  source_path = "abfss://my-container-name@storage-account-name.dfs.core.windows.net/table1" OR
  target_path = "abfss://my-container-name@storage-account-name.dfs.core.windows.net/table1";

範例:根據外部數據表名稱擷取歷程記錄

如果您不想手動擷取雲端記憶體路徑以尋找譜系,您可以使用下列函式來使用資料表名稱取得歷程數據。 您也可以在函式中將 system.access.table_lineage 取代為 system.access.column_lineage,如果您想查詢資料行譜系。

def getLineageForTable(table_name):
  table_path = spark.sql(f"describe detail {table_name}").select("location").head()[0]

  df = spark.read.table("system.access.table_lineage")
  return df.where(
    (df.source_table_full_name == table_name)
    | (df.target_table_full_name == table_name)
    | (df.source_path == table_path)
    | (df.target_path == table_path)
  )

然後使用下列命令來呼叫 函式,並顯示外部資料表的譜系記錄:

display(getLineageForTable("table_name"))