Compartir a través de

Referencia de tabla del sistema de eventos de sala limpia

  • Artículo

Importante

Esta tabla del sistema está en versión preliminar pública. Para acceder a la tabla, el esquema debe estar habilitado en el catálogo system. Para obtener más información, consulte Habilitación de esquemas de tabla del sistema.

La tabla de eventos de sala limpia registra las acciones realizadas por usted o sus colaboradores en salas limpias (versión preliminar pública) en 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:

Nombre de la columna Tipo de datos Descripción Ejemplo
account_id string Id. de la cuenta de Databricks 7af234db-66d7-4db3

-bbf0-956098224879
metastore_id string Id. del metastore de Unity Catalog 5a31ba44-bbf4-4174

-bf33-e1fa078e6765
event_id string Id. del evento de sala limpia db52a413-7a0a-4d49

-b742-7ae5f06bc4b2
clean_room_name string Nombre del destino asociado al evento de sala limpia market-analysis
central_clean_room_id string Id. de la sala limpia central e01b6a78-1336-47e1

-b63d-3e49aa5b627
initiator_global_metastore_id string Id. de metastore global del colaborador que ha iniciado el evento aws:us-west-2:ec22936d

-cd29-4421-a88a-883fb356776a
event_time timestamp Marca de tiempo de cuándo se ha producido el evento 2023-01-01T01:01:01.123
event_type string El tipo de evento. Vea Eventos de sala limpia registrados. CLEAN_ROOM_CREATED
clean_room_created_metadata struct Metadatos del tipo de evento CLEAN_ROOM_CREATED {

"collaborators": [

{"collaborator_global_metastore_id":

"aws:us-west-2:ec22936d-cd29-4421-a88a-883fb356776a"},

{"collaborator_global_metastore_id":

"azure:wesus:”3be05a26-5a83-478c-8428-9ef9aa67b5d0"}]

}
clean_room_deleted_metadata struct Metadatos del tipo de evento CLEAN_ROOM_DELETED {

"central_clean_room_id": "af0d4563-2267-412c-9d4a

-8a59c4895c18"

}
run_notebook_started_metadata struct Metadatos del tipo de evento RUN_NOTEBOOK_STARTED {

"notebook_name": "market analysis",

"notebook_checksum": "7072696E7468656C6C6F776F7264",

"run_id": "TaskRunId-634124444694206"

}
run_notebook_completed_metadata struct Metadatos del tipo de evento RUN_NOTEBOOK_COMPLETED {

"notebook_name": "market analysis",

"run_id": "TaskRunId-634124444694206",

"state": "SUCCESS",

"duration_in_seconds": 156

}
clean_room_assets_updated struct Metadatos del tipo de evento CLEAN_ROOM_ASSETS_UPDATED {

"added_assets": [{

"data_object_type": "TABLE",

"name": "sales",

"catalog": "demo"}],

"updated_assets":[],

"removed_assets": []

}

Eventos de sala limpia registrados

Esta tabla del sistema registra los siguientes eventos:

  • CLEAN_ROOM_CREATED: el usuario crea una sala limpia
  • CLEAN_ROOM_DELETED: el usuario elimina una sala limpia
  • RUN_NOTEBOOK_STARTED: El usuario inicia la ejecución de un notebook en una sala limpia
  • RUN_NOTEBOOK_COMPLETED: se completa la ejecución de un cuaderno. Compruebe el run_notebook_completed_metadata para ver si la ejecución se realizó correctamente o no.
  • CLEAN_ROOM_ASSETS_UPDATED: se actualizan los recursos de una sala limpia. Esto podría ser agregar, actualizar o eliminar recursos.

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

Nota:

Reemplace <clean_room_name> por el nombre de sala limpia especificado.

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)
   ELSE ""
 END AS event_metadata
 FROM system.access.clean_room_events
 WHERE clean_room_name = '<clean_room_name>'
ORDER BY event_time DESC

Enumerar todos los eventos iniciados por un colaborador especificado

Nota:

Reemplace <collaborator global metastore ID> por el identificador global de metastore del colaborador’, también conocido como identificador de uso compartido.

SELECT
 clean_room_name, 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)
   ELSE ""
 END AS event_metadata
 FROM system.access.clean_room_events
 WHERE initiator_global_metastore_id = '<collaborator global metastore ID>'
 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

Nota:

Reemplace el nombre de tabla default.sales por el nombre de 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 = 'default.sales')
ORDER BY clean_room_name, event_time DESC