Referencia de tabla del sistema de eventos de sala limpia

La tabla de eventos de salas limpias registra las acciones realizadas por usted o sus colaboradores en las salas limpias de su cuenta. En esta tabla se incluyen datos regionales de toda la cuenta.

Para más información sobre las salas limpias, vea ¿Qué son las salas limpias de Azure Databricks?.

Ruta de acceso de tabla: esta tabla del sistema se encuentra en system.access.clean_room_events.

Esquema de tabla del sistema de eventos de sala limpia

La tabla del sistema de eventos de sala limpia usa el esquema siguiente:

Eventos de sala limpia registrados

Esta tabla del sistema registra los siguientes eventos:

• CLEAN_ROOM_CREATED: el usuario crea una nueva sala limpia.
• CLEAN_ROOM_DELETED: el usuario elimina una sala limpia.
• RUN_NOTEBOOK_STARTED: el usuario inicia la ejecución de un cuaderno en una sala limpia.
• RUN_NOTEBOOK_COMPLETED: se completa la ejecución de un cuaderno. Compruebe run_notebook_completed_metadata para ver si la ejecución se ha realizado correctamente.
• CLEAN_ROOM_ASSETS_UPDATED: se actualizan los recursos de una sala limpia. Esto podría ser agregar, actualizar o eliminar recursos.
• OUTPUT_SCHEMA_DELETED: un esquema de salida expira y se elimina. El initiator_global_metastore_id de este tipo de evento siempre es system porque la eliminación se produce cuando expira el esquema de resultados.
• ASSET_REVIEW_CREATED: Usuario revisa un activo de sala limpia. Esto puede incluir revisiones generadas por el sistema en nombre del usuario.

Para evitar registros duplicados, solo se emite un registro para cada evento en salas limpias donde los colaboradores pertenecen al mismo metastore. Para las salas limpias en las que los colaboradores pertenecen a metastores independientes, se emiten registros únicos para cada colaborador.

Esquema de metadatos de ejecución completada del cuaderno

La columna run_notebook_completed_metadata contiene información de metadatos para eventos de RUN_NOTEBOOK_COMPLETED. Si la ejecución del cuaderno creó una tabla de salida, la información se registra mediante la estructura output_schema.

La columna run_notebook_completed_metadata usa el esquema siguiente:

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"

Eventos de revisión de recursos de sala limpia

La tabla de sistemas registra los metadatos sobre las acciones de revisión, como aprobaciones, rechazos y aprobaciones automáticas realizadas en recursos de sala limpia individuales. Los distintos tipos de revisión devuelven las siguientes estructuras:

Aprobación:

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

Rechazo:

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

Aprobación automática:

{
  "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",
}

Supervisión del uso facturable de la sala limpia

Para obtener más información sobre el uso y los costos de sala limpia, puede combinar esta tabla con la tabla billing.usagemediante la columna central_clean_room_id. En la tabla billing.usage, el uso de sala limpia se atribuye mediante la clave usage_metadata.central_clean_room_id.

Consultas de ejemplo

Las siguientes consultas de ejemplo le ayudan a obtener información sobre la actividad de sala limpia en la cuenta:

• Enumerar todos los eventos de una sala limpia especificada
• Enumerar todos los eventos iniciados por un colaborador especificado
• Enumerar todos los colaboradores pertinentes de las salas limpias
• Enumerar las ejecuciones de cuadernos más lentas
• Tasa de ejecución correcta para cada cuaderno
• Enumerar todos los eventos en los que se ha agregado una tabla especificada a las salas limpias

Enumerar todos los eventos de una sala limpia especificada

Reemplace por :central_clean_room_id el identificador central de la sala limpia, que se puede encontrar en el panel de detalles de la sala limpia junto a Id. central.

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

Enumerar todos los eventos iniciados por un colaborador especificado

Para el parámetro :initiator_global_metastore_id, escriba el identificador global de metastore del colaborador, también conocido como identificador de compartición. En :collaborator_alias, escriba el alias del colaborador. De forma predeterminada, los dos alias posibles son creator para el creador de la sala limpia y collaborator para la otra parte.

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

Enumerar todos los colaboradores pertinentes de las salas limpias

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'

Enumerar las ejecuciones de cuadernos más lentas

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

Tasa de ejecución correcta para cada cuaderno

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

Enumerar todos los eventos en los que se ha agregado una tabla especificada a las salas limpias

En el parámetro :table_name_string, escriba el nombre de la tabla especificado.

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