Referencia de tabla del sistema de eventos de sala limpia
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 |
Consulte Metadatos de ejecución completada del cuaderno |
clean_room_assets_updated_metadata |
struct | Metadatos del tipo de evento CLEAN_ROOM_ASSETS_UPDATED |
{ "added_assets": [{ "data_object_type": "TABLE", "name": "sales", "catalog": "demo"}], "updated_assets":[], "removed_assets": [] } |
delete_output_schema_metadata |
struct | Metadatos del tipo de evento DELETE_OUTPUT_SCHEMA |
{ "name": "output_schema_55555", "owner_global_metastore_id": "aws:us-west-2:555555-55...", "action": "DELETE" expire_time: "2025-01-14T15:28:19.000Z" } |
initiator_collaborator_alias |
string | Alias del colaborador que inició el evento. Para las salas limpias creadas a través de la interfaz de usuario, el valor es creator o collaborator . En el caso de las salas limpias creadas a través de la API, son los valores personalizados especificados en la creación. |
creator |
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. Comprueberun_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.DELETE_OUTPUT_SCHEMA
: un esquema de salida expira y se elimina. Elinitiator_global_metastore_id
de este tipo de evento siempre essystem
porque la eliminación se produce cuando expira el esquema de resultados.
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"
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.usage
mediante 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 :central_clean_room_id
por el identificador de sala limpia central, 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)
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 uso compartido. 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)
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