Informations de référence sur la table système des événements de salle blanche

La table des événements de salle de nettoyage enregistre les actions effectuées par vous ou vos collaborateurs sur des salles blanches dans votre compte. Ce tableau inclut les données régionales de votre compte.

Pour plus d’informations sur les salles blanches, consultez Présentation des salles blanches Azure Databricks.

Chemin d’accès de la table : cette table système se trouve à l’emplacement system.access.clean_room_events.

Schéma de table système des événements de salle blanche

La table système des événements de salle blanche utilise le schéma suivant :

Événements de salle blanche journalisés

Cette table système journalise les événements suivants :

• CLEAN_ROOM_CREATED: l’utilisateur crée une salle propre.
• CLEAN_ROOM_DELETED : l’utilisateur supprime une salle blanche.
• RUN_NOTEBOOK_STARTED : l’utilisateur lance une exécution de notebook dans une salle blanche.
• RUN_NOTEBOOK_COMPLETED : une exécution de bloc-notes est terminée. Vérifiez le run_notebook_completed_metadata pour voir si l’exécution a réussi ou non.
• CLEAN_ROOM_ASSETS_UPDATED : les ressources d’une salle blanche sont mises à jour. Cela peut être l’ajout, la mise à jour ou la suppression de ressources.
• DELETE_OUTPUT_SCHEMA: un schéma de sortie expire et est supprimé. Le initiator_global_metastore_id de ce type d’événement est toujours system, car la suppression se produit lorsque le schéma de sortie expire.

Pour empêcher les enregistrements en double, un seul enregistrement est émis pour chaque événement dans des salles propres où les collaborateurs appartiennent au même metastore. Pour les salles propres où les collaborateurs appartiennent à des metastores distincts, des enregistrements uniques sont émis pour chaque collaborateur.

Schéma de métadonnées d’exécution de notebook terminé

La colonne run_notebook_completed_metadata contient des informations de métadonnées pour les événements RUN_NOTEBOOK_COMPLETED. Si une table de sortie a été créée par l’exécution du notebook, les informations sont journalisées à l’aide du struct output_schema.

La colonne run_notebook_completed_metadata utilise le schéma suivant :

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"

Contrôler l'utilisation facturable de la salle de nettoyage

Pour en savoir plus sur l’utilisation et les coûts de la salle blanche, vous pouvez associer ce tableau-ci à la table billing.usage à l’aide de la colonne central_clean_room_id. Dans le tableau billing.usage, l'utilisation des salles blanches est attribuée à l'aide de la clé usage_metadata.central_clean_room_id.

Exemples de requêtes

Les exemples de requêtes suivants vous aident à obtenir des informations sur l’activité de salle blanche dans votre compte :

• Répertorier tous les événements d’une salle blanche spécifiée
• Répertorier tous les événements initiés par un collaborateur spécifié
• Répertorier tous les collaborateurs pertinents des salles blanches
• Répertorier les exécutions de notebook les plus lentes
• Taux de réussite des exécutions pour chaque notebook
• Répertorier tous les événements dans lesquels une table spécifiée a été ajoutée aux salles blanches

Répertorier tous les événements d’une salle blanche spécifiée

Remplacez :central_clean_room_id par l’ID central de la salle blanche, qui se trouve dans le panneau des détails de la salle blanche à côté de l’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

Répertorier tous les événements initiés par un collaborateur spécifié

Pour le paramètre :initiator_global_metastore_id, entrez l’ID global du metastore du collaborateur, également appelé identificateur de partage. Pour :collaborator_alias, entrez l’alias du collaborateur. Par défaut, les deux alias possibles sont creator pour le créateur de la salle blanche et collaborator pour l’autre partie.

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

Répertorier tous les collaborateurs pertinents des salles blanches

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'

Répertorier les exécutions de notebook les plus lentes

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

Taux de réussite des exécutions pour chaque 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

Répertorier tous les événements dans lesquels une table spécifiée a été ajoutée aux salles blanches

Pour le :table_name_string paramter, entrez le nom de votre table spécifiée.

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