データ品質モニタリング結果 システムテーブル リファレンス

備考

プレビュー

この機能は パブリック プレビュー段階です。

このページでは、データ品質モニタリング結果のシステムテーブルのスキーマの概要を説明し、クエリーのサンプルを掲載しています。このテーブルには、メタストアでデータ品質モニタリングが有効になっているすべてのテーブルについて、最新性と完全性のチェック結果が格納されます。

テーブルパス : system.data_quality_monitoring.table_results

このテーブルにアクセスできるのはアカウント管理者のみであり、必要に応じて他のユーザーにアクセス権を付与する必要があります。システムテーブルはdefaultストレージを使用します。サンプル値が含まれているため、他のユーザーにアクセス権を付与する際には注意してください。

データ品質モニタリング結果テーブルのスキーマ

system.data_quality_monitoring.table_resultsテーブルは次のスキーマを使用します:

列名	コンテンツ（ structデータ型の場合）	データ型	説明	サンプルデータ
event_time		timestamp	行が生成された時刻。	2025-06-27T12:00:00
catalog_name		string	カタログの名前。テーブルを識別するために使用されます。	main
schema_name		string	スキーマの名前。テーブルを識別するために使用されます。	default
table_name		string	テーブルの名前。テーブルを識別するために使用されます。	events
catalog_id		string	カタログの安定した ID。	3f1a7d6e-9c59-4b76-8c32-8d4c74e289fe
schema_id		string	スキーマの安定した ID。	3f1a7d6e-9c59-4b76-8c32-8d4c74e289fe
table_id		string	テーブルの安定した ID。	3f1a7d6e-9c59-4b76-8c32-8d4c74e289fe
status		string	テーブル レベルで統合されたヘルス ステータス。いずれかのチェックまたはグループが正常でない場合は、「異常」となります。	Healthy、Unhealthy、 Unknown
freshness		struct	鮮度チェック。
	status	string	全体的な鮮度の状態。	Unhealthy
	commit_freshness	struct	コミットの鮮度チェック結果。
completeness		struct	完全性チェックの結果。
	status	string	完全性チェックのステータス。	Unhealthy
	total_row_count	struct	一定期間にわたるテーブル内の行の合計数。
	daily_row_count	struct	毎日追加される行数。

列名	コンテンツ（ structデータ型の場合）	データ型	説明	サンプルデータ
event_time		timestamp	行が生成された時刻。	2025-06-27T12:00:00
catalog_name		string	カタログの名前。テーブルを識別するために使用されます。	main
schema_name		string	スキーマの名前。テーブルを識別するために使用されます。	default
table_name		string	テーブルの名前。テーブルを識別するために使用されます。	events
catalog_id		string	カタログの安定した ID。	3f1a7d6e-9c59-4b76-8c32-8d4c74e289fe
schema_id		string	スキーマの安定した ID。	3f1a7d6e-9c59-4b76-8c32-8d4c74e289fe
table_id		string	テーブルの安定した ID。	3f1a7d6e-9c59-4b76-8c32-8d4c74e289fe
status		string	テーブル レベルで統合されたヘルス ステータス。いずれかのチェックまたはグループが正常でない場合は、「異常」となります。	Healthy、Unhealthy、 Unknown
freshness		struct	鮮度チェック。
	status	string	全体的な鮮度の状態。	Unhealthy
	commit_freshness	struct	コミットの鮮度チェック結果。
completeness		struct	完全性チェックの結果。
	status	string	完全性チェックのステータス。	Unhealthy
	total_row_count	struct	一定期間にわたるテーブル内の行の合計数。
	daily_row_count	struct	毎日追加される行数。

commit_freshness配列構造

commit_freshness構造体には次のものが含まれています。

アイテム名	データ型	説明	サンプルデータ
status	string	コミットの鮮度チェックのステータス。	Unhealthy
error_code	string	チェック中にエラー メッセージが検出されました。	FAILED_TO_FIT_MODEL
last_value	timestamp	最後のコミットのタイムスタンプ。	2025-06-27T11:30:00
predicted_value	timestamp	テーブルが更新されるはずだった予測時刻。	2025-06-27T11:45:00

アイテム名	データ型	説明	サンプルデータ
status	string	コミットの鮮度チェックのステータス。	Unhealthy
error_code	string	チェック中にエラー メッセージが検出されました。	FAILED_TO_FIT_MODEL
last_value	timestamp	最後のコミットのタイムスタンプ。	2025-06-27T11:30:00
predicted_value	timestamp	テーブルが更新されるはずだった予測時刻。	2025-06-27T11:45:00

total_row_countとdaily_row_count配列構造

total_row_countおよびdaily_row_count構造体には次の内容が含まれます。

アイテム名	データ型	説明	サンプルデータ
status	string	チェックのステータス。	Unhealthy
error_code	string	チェック中にエラー メッセージが検出されました。	FAILED_TO_FIT_MODEL
last_value	int	過去 24 時間に観測された行数。	500
min_predicted_value	int	過去 24 時間の最小予想行数。	10
max_predicted_value	int	過去 24 時間の予想行数の最大数。	1000

アイテム名	データ型	説明	サンプルデータ
status	string	チェックのステータス。	Unhealthy
error_code	string	チェック中にエラー メッセージが検出されました。	FAILED_TO_FIT_MODEL
last_value	int	過去 24 時間に観測された行数。	500
min_predicted_value	int	過去 24 時間の最小予想行数。	10
max_predicted_value	int	過去 24 時間の予想行数の最大数。	1000

クエリの例

実行する前に、問題の値を自分のものに置き換えてください。

スキーマ内の現在のインシデントをすべて取得する

SQL

WITH latest_rows AS (
    SELECT
        *,
        ROW_NUMBER() OVER (
            PARTITION BY table_id
            ORDER BY event_time DESC
        ) AS rn
    FROM
      system.data_quality_monitoring.table_results
    WHERE
      catalog_name = "c"
      AND schema_name = "s"
)

SELECT *
FROM latest_rows
WHERE
  rn = 1
  AND status = "Unhealthy"

スキーマ内で現在鮮度の問題の影響を受けているすべてのテーブルを取得します

SQL

WITH latest_rows AS (
    SELECT
        *,
        ROW_NUMBER() OVER (
            PARTITION BY table_id
            ORDER BY event_time DESC
        ) AS rn
    FROM
      system.data_quality_monitoring.table_results
    WHERE
      catalog_name = "c"
      AND schema_name = "s"
)

SELECT *
FROM latest_rows
WHERE rn = 1
  AND freshness.status = "Unhealthy"

テーブルのすべての履歴レコードを取得する

SQL

SELECT *
FROM system.data_quality_monitoring.table_results
WHERE
  catalog_name = "c"
  AND schema_name = "s"
  AND table_name = "t"