清洁室事件系统表参考

无尘室事件记录表记录您或您的协作者在您的帐户中无尘室的操作。 此表包含帐户中的区域数据。

有关清洁室的详细信息，请参阅什么是 Azure Databricks 清洁室？。

表路径：此系统表位于 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：用户审阅一个无尘室资产。 这可以包括系统代表用户生成的评论。

为防止重复记录，协作者属于同一元存储的清理室中的每个事件只发出一条记录。 对于协作者属于不同元数据存储的洁净室，会为每个协作者生成唯一记录。

已完成的笔记本运行元数据架构

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。

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