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

A tabela de eventos de salas limpas regista as ações realizadas por si ou pelos seus colaboradores em salas limpas na sua conta. Esta tabela inclui dados regionais de toda a sua conta.

Para obter mais informações sobre salas limpas, consulte O que é o Azure Databricks Clean Rooms?.

Caminho da tabela: Esta tabela do sistema está localizada em system.access.clean_room_events.

Esquema de tabela do sistema de eventos em sala limpa

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

Eventos de sala branca registados

Esta tabela do sistema regista os seguintes eventos:

• CLEAN_ROOM_CREATED: O usuário cria uma nova sala limpa.
• CLEAN_ROOM_DELETED: O utilizador elimina uma sala limpa.
• RUN_NOTEBOOK_STARTED: O utilizador inicia uma execução de notebook numa sala limpa.
• RUN_NOTEBOOK_COMPLETED: Uma 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 uma sala limpa são atualizados. Isso pode ser adicionar, atualizar ou excluir ativos.
• OUTPUT_SCHEMA_DELETED: Um esquema de saída expira e é excluído. A initiator_global_metastore_id para esse tipo de evento é sempre system porque a exclusão ocorre quando o esquema de saída expira.
• ASSET_REVIEW_CREATED: O usuário analisa um ativo de sala limpa. Isso pode incluir revisões geradas pelo sistema em nome do usuário.

Para evitar registros duplicados, apenas um registro é emitido para cada evento em salas limpas onde os colaboradores pertencem ao mesmo metastore. Para salas limpas onde os colaboradores pertencem a metastores separados, são emitidos registos únicos para cada colaborador.

Esquema de metadados da execução concluída do notebook

A coluna run_notebook_completed_metadata contém informações de metadados para eventos RUN_NOTEBOOK_COMPLETED. Se uma tabela de saída foi criada pela execução do notebook, as informações são registadas usando a estrutura .

A coluna run_notebook_completed_metadata usa o seguinte esquema:

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 revisão de ativos de sala limpa

A tabela dos sistemas regista metadados sobre ações de revisão, como aprovações, rejeições e aprovações automáticas realizadas em cada ativo da sala limpa. Os diferentes tipos de revisão retornam as seguintes estruturas:

Aprovação:

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

Rejeição:

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

Aprovação 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",
}

Monitore o uso faturável da sala limpa

Para saber mais sobre o uso e os custos da sala limpa, você pode unir esta tabela com a tabela billing.usage usando a coluna central_clean_room_id. Na tabela billing.usage, o uso da sala limpa atribui-se através da chave usage_metadata.central_clean_room_id.

Exemplos de consultas

As consultas de exemplo a seguir ajudam você a obter informações sobre a atividade de sala limpa em sua conta:

• Listar todos os eventos a partir de uma sala limpa determinada
• Listar todos os eventos iniciados por um colaborador especificado
• Listar todos os colaboradores relevantes das salas limpas
• Listar as execuções mais lentas do portátil
• Taxa de execução bem-sucedida para cada notebook
• Listar todos os eventos em que uma tabela especificada foi adicionada às clean rooms

Listar todos os eventos de uma sala limpa especificada

Substitua :central_clean_room_id pelo ID central da sala limpa, que pode ser encontrado no painel de detalhes da sala limpa ao lado do 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

Listar todos os eventos iniciados por um colaborador especificado

Para o :initiator_global_metastore_id parâmetro, insira o ID global do metastore do colaborador, também conhecido como identificador de compartilhamento. Para :collaborator_alias, insira o alias do colaborador. Por padrão, os dois aliases possíveis são creator para o criador da sala limpa e collaborator para a outra 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

Listar 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 as execuções de notebook mais 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

Taxa de sucesso de execução 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 especificada foi adicionada às salas limpas

Para o paramter :table_name_string, insira o 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 = :table_name_string
  )
ORDER BY
  clean_room_name,
  event_time DESC