クリーン ルーム イベント システム テーブル リファレンス

[クリーン ルーム イベント] テーブルには、自分または共同作業者がアカウントのクリーン ルームで実行したアクションが記録されます。 このテーブルには、自分のアカウント全体からのリージョンに関するデータが含まれます。

クリーン ルームについて詳しくは、「Azure Databricks Clean Rooms とは」をご覧ください。

テーブル パス: このシステム テーブルは、 system.access.clean_room_eventsにあります。

クリーン ルーム イベント システム テーブルのスキーマ

クリーン ルーム イベント システム テーブルでは、次のスキーマが使われます。

クリーンルームのイベントが記録される

このシステム テーブルには、次のイベントがログされます。

• CLEAN_ROOM_CREATED: ユーザーが新しいクリーン ルームを作成します。
• CLEAN_ROOM_DELETED: ユーザーがクリーン ルームを削除します。
• RUN_NOTEBOOK_STARTED: ユーザーは、クリーン ルームでノートブックの実行を開始します。
• RUN_NOTEBOOK_COMPLETED: ノートブックの実行が完了した。 run_notebook_completed_metadata を確認して、実行が成功したかどうかを確認します。
• CLEAN_ROOM_ASSETS_UPDATED: クリーン ルームの資産が更新されます。 これは、資産の追加、更新、または削除です。
• OUTPUT_SCHEMA_DELETED: 出力スキーマの有効期限が切れ、削除されます。 出力スキーマの有効期限が切れると削除が行われるため、このイベントの種類の initiator_global_metastore_id は常に system されます。
• ASSET_REVIEW_CREATED: ユーザーがクリーン ルーム資産をレビューします。 これには、ユーザーに代わってシステムによって生成されたレビューを含めることができます。

重複レコードを防ぐために、コラボレーターが同じメタストアに属しているクリーン ルームのイベントごとに 1 つのレコードのみが生成されます。 コラボレーターが別々のメタストアに属しているクリーン ルームでは、コラボレーターごとに一意のレコードが生成されます。

ノートブック実行の完了メタデータ スキーマ

run_notebook_completed_metadata 列には、RUN_NOTEBOOK_COMPLETED イベントのメタデータ情報が含まれています。 ノートブックの実行によって 出力テーブル 作成された場合、情報は output_schema 構造体を使用してログに記録されます。

run_notebook_completed_metadata 列では、次のスキーマを使用します。

notebook_name: "example_notebook"
run_id: "TaskRunId-55555129818570"
state: "SUCCESS"
duration_in_seconds: 120
output_schema:
  name: "output_schema_123450129818570"
  owner_global_metastore_id: "aws:us-west-2:55555e-55bc-55a5-55ab-555d5ec16013"
  action: "CREATE"
  expire_time: "2025-01-14T15:28:19.000Z"
  assets_added:
    0:
    name: "important_data"
    data_object_type: "TABLE"

クリーン ルーム資産レビュー イベント

システム テーブルには、個々のクリーン ルーム 資産に対して実行された承認、却下、自動承認などのレビュー アクションに関するメタデータが記録されます。 レビューの種類が異なると、次の構造体が返されます。

承認：

{
  "asset_name": "Market Analysis",
  "data_object_type": "NOTEBOOK_FILE",
 "notebook_metadata: {
    “etag": "f2429adc02d548bacc11db6c8891ec2548d38b4798a80810fbc8be784af22931",
  }
  "review_state": "APPROVED",
  "review_subreason": null,
  "auto_approval_rule_id": null,
}

拒絶：

{
  "asset_name": "Market Analysis",
  "data_object_type": "NOTEBOOK_FILE",
 "notebook_metadata: {
    “etag": "f2429adc02d548bacc11db6c8891ec2548d38b4798a80810fbc8be784af22931",
  }
  "review_state": "REJECTED",
  "review_subreason": null,
  "auto_approval_rule_id": null,
}

自動承認:

{
  "asset_name": "Market Analysis",
  "data_object_type": "NOTEBOOK_FILE",
 "notebook_metadata: {
    “etag": "f2429adc02d548bacc11db6c8891ec2548d38b4798a80810fbc8be784af22931",
  }
  "review_state": "APPROVED",
  "review_subreason": "AUTO_APPROVED",
  "auto_approval_rule_id": "d0ec563f-6d58-4f38-99c0-376b779e3747",
}

クリーン ルームの課金対象使用量を監視

クリーン ルームの使用状況とコストの詳細については、billing.usage列を使用して、このテーブルを central_clean_room_id テーブルと結合ができます。 billing.usageテーブルでは、クリーン ルームの使用状況はusage_metadata.central_clean_room_id キーを使用して帰属しています。

サンプル クエリ

次のサンプル クエリは、アカウントでのクリーン ルーム アクティビティに関する分析情報を得るのに役立ちます。

• 指定したクリーン ルームのすべてのイベントを一覧表示する
• 指定したコラボレーターによって開始されたすべてのイベントを一覧表示する
• クリーン ルームに関連するすべてのコラボレーターを一覧表示する
• 最も遅いノートブックの実行を一覧表示する
• すべてのノートブックの成功した実行の割合
• 指定したテーブルがクリーン ルームに追加されたすべてのイベントを一覧表示する

指定したクリーン ルームのすべてのイベントを一覧表示する

:central_clean_room_idを中央のクリーン ルーム ID に置き換えます。この ID は、中央 ID の横にあるクリーン ルームの詳細パネルにあります。

SELECT
 event_time, initiator_global_metastore_id, event_type,
 CASE
   WHEN event_type = 'CLEAN_ROOM_CREATED' THEN to_json(clean_room_created_metadata)
   WHEN event_type = 'CLEAN_ROOM_DELETED' THEN to_json(clean_room_deleted_metadata)
   WHEN event_type = 'RUN_NOTEBOOK_STARTED' THEN to_json(run_notebook_started_metadata)
   WHEN event_type = 'RUN_NOTEBOOK_COMPLETED' THEN to_json(run_notebook_completed_metadata)
   WHEN event_type = 'CLEAN_ROOM_ASSETS_UPDATED' THEN to_json(clean_room_assets_updated_metadata)
   WHEN event_type = 'OUTPUT_SCHEMA_DELETED' THEN to_json(output_schema_deleted_metadata)
   WHEN event_type = 'ASSET_REVIEW_CREATED' THEN to_json(asset_review_created_metadata)
   ELSE ""
 END AS event_metadata
 FROM system.access.clean_room_events
 WHERE central_clean_room_id = :central_clean_room_id
ORDER BY event_time DESC

指定したコラボレーターによって開始されたすべてのイベントを一覧表示する

:initiator_global_metastore_id パラメーターには、コラボレーターのグローバル メタストア ID (共有識別子とも呼ばれます) を入力します。 :collaborator_aliasの場合は、コラボレーターのエイリアスを入力します。 既定では、クリーンルームの作成者には creator、もう一方の当事者には collaborator の2つのエイリアスが割り当てられます。

SELECT
 clean_room_name, central_clean_room_id, event_type, event_time,
 CASE
   WHEN event_type = 'CLEAN_ROOM_CREATED' THEN to_json(clean_room_created_metadata)
   WHEN event_type = 'CLEAN_ROOM_DELETED' THEN to_json(clean_room_deleted_metadata)
   WHEN event_type = 'RUN_NOTEBOOK_STARTED' THEN to_json(run_notebook_started_metadata)
   WHEN event_type = 'RUN_NOTEBOOK_COMPLETED' THEN to_json(run_notebook_completed_metadata)
   WHEN event_type = 'CLEAN_ROOM_ASSETS_UPDATED' THEN to_json(clean_room_assets_updated_metadata)
   WHEN event_type = 'OUTPUT_SCHEMA_DELETED' THEN to_json(output_schema_deleted_metadata)
   WHEN event_type = 'ASSET_REVIEW_CREATED' THEN to_json(asset_review_created_metadata)
   ELSE ""
 END AS event_metadata
 FROM system.access.clean_room_events
 WHERE initiator_global_metastore_id = :initiator_global_metastore_id AND (initiator_collaborator_alias = :collaborator_alias OR initiator_collaborator_alias IS NULL)
 ORDER BY clean_room_name, event_time DESC

クリーン ルームに関連するすべてのコラボレーターを一覧表示する

SELECT DISTINCT explode(transform(clean_room_created_metadata.collaborators, x -> x.collaborator_global_metastore_id)) AS collaborator
FROM system.access.clean_room_events
WHERE event_type = 'CLEAN_ROOM_CREATED'

最も遅いノートブックの実行を一覧表示する

SELECT
 clean_room_name,
 run_notebook_completed_metadata.notebook_name AS notebook_name,
 run_notebook_completed_metadata.duration_in_seconds AS duration_in_seconds,
 run_notebook_completed_metadata.run_id AS run_id
FROM system.access.clean_room_events
WHERE event_type = 'RUN_NOTEBOOK_COMPLETED'
 AND run_notebook_completed_metadata.state = 'SUCCESS'
 AND run_notebook_completed_metadata.duration_in_seconds IS NOT NULL
ORDER BY duration_in_seconds DESC

各ノートブックの実行成功率

SELECT
 clean_room_name,
 run_notebook_completed_metadata.notebook_name AS notebook_name,
 ROUND(COUNT(CASE WHEN run_notebook_completed_metadata.state = 'SUCCESS' THEN 1 END) * 1.0 / COUNT(*) * 100) AS success_rate
FROM system.access.clean_room_events
WHERE event_type = 'RUN_NOTEBOOK_COMPLETED'
GROUP BY clean_room_name, notebook_name
ORDER BY clean_room_name, notebook_name

指定したテーブルがクリーン ルームに追加されたすべてのイベントを一覧表示する

:table_name_string パラメーターには、指定したテーブル名を入力します。

SELECT
  clean_room_name,
  initiator_global_metastore_id,
  event_time,
  clean_room_assets_updated_metadata
FROM
  system.access.clean_room_events
WHERE
  event_type = 'CLEAN_ROOM_ASSETS_UPDATED'
  AND exists(
    clean_room_assets_updated_metadata.added_assets,
    item -> item.data_object_type = 'TABLE'
    AND item.name = :table_name_string
  )
ORDER BY
  clean_room_name,
  event_time DESC