Referência de tabela do sistema de eventos de sala limpa

Prévia

Essa tabela do sistema está em Pré-visualização Pública. Para acessar a tabela, o esquema deve estar habilitado em seu catálogo system. Para obter mais informações, consulte Habilitar esquemas de tabelas do sistema.

A tabela clean_room_events registra as ações realizadas pelo senhor ou por seus colaboradores em salas limpas (Public Preview) no seu site account. Essa tabela inclui dados regionais do site account.

Para obter mais informações sobre salas limpas, consulte What is Databricks Clean Rooms?

Esquema de tabela do sistema de eventos de sala limpa

A tabela do sistema de eventos da sala limpa usa o seguinte esquema:

Nome da coluna

Tipo de dados

Descrição

Exemplo

account_id

string

O ID do site Databricks account

7af234db-66d7-4db3

-bbf0-956098224879

metastore_id

string

O ID do metastore do Unity Catalog>

5a31ba44-bbf4-4174

-bf33-e1fa078e6765

event_id

string

O ID do evento da sala limpa

db52a413-7a0a-4d49

-b742-7ae5f06bc4b2

clean_room_name

string

Nome da sala limpa associada ao evento

market-analysis

central_clean_room_id

string

A identificação da sala limpa central

e01b6a78-1336-47e1

-b63d-3e49aa5b627

initiator_global_metastore_id

string

ID global do metastore do colaborador que iniciou o evento

aws:us-west-2:ec22936d

-cd29-4421-a88a-883fb356776a

event_time

timestamp

Registro de data e hora em que o evento ocorreu

2023-01-01T01:01:01.123

event_type

string

O tipo de evento. Veja os registros de eventos da sala limpa.

CLEAN_ROOM_CREATED

clean_room_created_metadata

struct

Os metadados do 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

Os metadados do tipo de evento CLEAN_ROOM_DELETED

{

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

-8a59c4895c18"

}

run_notebook_started_metadata

struct

Os metadados do tipo de evento RUN_NOTEBOOK_STARTED

{

"notebook_name": "market analysis",

"notebook_checksum": "7072696E7468656C6C6F776F7264",

"run_id": "TaskRunId-634124444694206"

}

run_notebook_completed_metadata

struct

Os metadados do 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

Os metadados do tipo de evento CLEAN_ROOM_ASSETS_UPDATED

{

"added_assets": [{

"data_object_type": "TABLE",

"name": "sales",

"catalog": "demo"}],

"updated_assets":[],

"removed_assets": []

}

registra eventos de sala limpa

Essa tabela do sistema logs os seguintes eventos:

  • CLEAN_ROOM_CREATED: O usuário cria uma nova sala limpa

  • CLEAN_ROOM_DELETED: O usuário exclui uma sala limpa

  • RUN_NOTEBOOK_STARTED: O usuário inicia a execução de um Notebook em uma sala limpa

  • RUN_NOTEBOOK_COMPLETED: A execução do Notebook foi concluída. Verifique o run_notebook_completed_metadata para ver se a execução foi bem-sucedida ou não.

  • CLEAN_ROOM_ASSETS_UPDATED: Os ativos de um quarto limpo são atualizados. Isso pode ser feito adicionando, atualizando ou excluindo ativos.

Monitore o uso faturável da sala limpa

Para saber mais sobre o uso e os custos da sala limpa, o senhor pode join essa tabela com a tabela billing.usage usando a coluna central_clean_room_id. Na tabela billing.usage, o uso da sala limpa é atribuído usando o usage_metadata.central_clean_room_id key.

Consultas de amostra

Os exemplos de consultas a seguir ajudam o senhor a entender a atividade da sala limpa em seu site account:

Listar todos os eventos de uma sala limpa específica

Observação

Substitua <clean_room_name> pelo nome da sala limpa especificada.

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

Listar todos os eventos iniciados por um colaborador específico

Observação

Substitua <collaborator global metastore ID> pelo ID do metastore global do colaborador, também conhecido como identificador de compartilhamento.

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

Liste todos os colaboradores relevantes das salas limpas 

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'

Listar a execução mais lenta do Notebook 

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

Taxa de execução bem-sucedida para cada Notebook 

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

Listar todos os eventos em que uma tabela específica foi adicionada a salas limpas

Observação

Substitua o nome da tabela default.sales pelo nome da tabela especificada.

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