Verweis auf die Systemtabelle für Reinraumereignisse

Die Tabelle "Clean Room"-Ereignisse zeichnet Aktionen auf, die von Ihnen oder Ihren Mitarbeitern für Reinräume (öffentliche Vorschau) in Ihrem Konto ausgeführt werden. Diese Tabelle enthält regionale Daten aus Ihrem gesamten Konto.

Weitere Informationen zu Reinräumen finden Sie unter Was sind Azure Databricks-Reinräume?.

Tabellenpfad: Diese Systemtabelle befindet sich unter clean_room_events.

Schema einer Systemtabelle für Reinraumereignisse

Die Systemtabelle für Reinraumereignisse verwendet das folgende Schema:

Protokollierte Reinraumereignisse

Diese Systemtabelle protokolliert die folgenden Ereignisse:

• CLEAN_ROOM_CREATED: Der Benutzer erstellt einen neuen Reinraum.
• CLEAN_ROOM_DELETED: Der Benutzer löscht einen Reinraum.
• RUN_NOTEBOOK_STARTED: Der Benutzer initiiert eine Notebookausführung in einem Reinraum.
• RUN_NOTEBOOK_COMPLETED: Eine Notebookausführung ist abgeschlossen. Überprüfen Sie die run_notebook_completed_metadata, um festzustellen, ob die Ausführung erfolgreich war.
• CLEAN_ROOM_ASSETS_UPDATED: Die Ressourcen eines Reinraums werden aktualisiert. Dabei kann es sich um das Hinzufügen, Aktualisieren oder Löschen von Ressourcen handeln.

Überwachen der abrechenbaren Reinraumnutzung

Wenn Sie mehr über die Reinraumnutzung und die entsprechenden Kosten erfahren möchten, können Sie diese Tabelle mithilfe der billing.usageSpalte mit der central_clean_room_id-Tabelle verknüpfen. In der billing.usage-Tabelle wird die Reinraumnutzung über den Schlüssel usage_metadata.central_clean_room_id zugeordnet.

Beispielabfragen

Die folgenden Beispielabfragen helfen Ihnen, Einblicke in die Reinraumaktivitäten in Ihrem Konto zu erhalten:

• Auflisten aller Ereignisse aus einem angegebenen Reinraum
• Auflisten aller Ereignisse, die von einem angegebenen Mitarbeiter initiiert wurden
• Auflisten aller relevanten Mitarbeiter der Reinräume
• Auflisten der langsamsten Notebookausführungen
• Ausführungserfolgsrate für jedes Notebook
• Auflisten aller Ereignisse, bei denen eine angegebene Tabelle zu Reinräumen hinzugefügt wurde

Auflisten aller Ereignisse aus einem angegebenen Reinraum

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

Auflisten aller Ereignisse, die von einem angegebenen Mitarbeiter initiiert wurden

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

Auflisten aller relevanten Mitarbeiter der Reinräume

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'

Auflisten der langsamsten Notebookausführungen

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

Ausführungserfolgsrate für jedes 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

Auflisten aller Ereignisse, bei denen eine angegebene Tabelle zu Reinräumen hinzugefügt wurde

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