Freigeben über

Verweis auf die Systemtabelle für Reinraumereignisse

  • Artikel

Wichtig

Diese Systemtabelle befindet sich in der Public Preview. Um auf die Tabelle zuzugreifen, muss das Schema in Ihrem system Katalog aktiviert sein. Weitere Informationen finden Sie unter Aktivieren des Systemtabellenschemas.

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:

Spaltenname Datentyp Beschreibung Beispiel
account_id Zeichenfolge Die ID des Databricks-Kontos 7af234db-66d7-4db3

-bbf0-956098224879
metastore_id Zeichenfolge Die ID des Unity Catalog-Metastore 5a31ba44-bbf4-4174

-bf33-e1fa078e6765
event_id Zeichenfolge Die ID des Reinraumereignisses db52a413-7a0a-4d49

-b742-7ae5f06bc4b2
clean_room_name Zeichenfolge Name des dem Ereignis zugeordneten Reinraums market-analysis
central_clean_room_id Zeichenfolge Die ID des zentralen Reinraums e01b6a78-1336-47e1

-b63d-3e49aa5b627
initiator_global_metastore_id Zeichenfolge Globale Metastore-ID des Mitarbeiters, der das Ereignis initiiert hat aws:us-west-2:ec22936d

-cd29-4421-a88a-883fb356776a
event_time Zeitstempel Zeitstempel des Zeitpunkts, an dem das Ereignis stattgefunden hat 2023-01-01T01:01:01.123
event_type Zeichenfolge Typ des Ereignisses Weitere Informationen finden Sie unter Protokollierte Reinraumereignisse. CLEAN_ROOM_CREATED
clean_room_created_metadata struct Die Metadaten des Ereignistyps 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 Die Metadaten des Ereignistyps CLEAN_ROOM_DELETED {

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

-8a59c4895c18"

}
run_notebook_started_metadata struct Die Metadaten des Ereignistyps RUN_NOTEBOOK_STARTED {

"notebook_name": "market analysis",

"notebook_checksum": "7072696E7468656C6C6F776F7264",

"run_id": "TaskRunId-634124444694206"

}
run_notebook_completed_metadata struct Die Metadaten des Ereignistyps RUN_NOTEBOOK_COMPLETED {

"notebook_name": "market analysis",

"run_id": "TaskRunId-634124444694206",

"state": "SUCCESS",

"duration_in_seconds": 156

}
clean_room_assets_updated struct Die Metadaten des Ereignistyps CLEAN_ROOM_ASSETS_UPDATED {

"added_assets": [{

"data_object_type": "TABLE",

"name": "sales",

"catalog": "demo"}],

"updated_assets":[],

"removed_assets": []

}

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

Hinweis

Ersetzen Sie <clean_room_name> durch den angegebenen Reinraumnamen.

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

Hinweis

Ersetzen Sie <collaborator global metastore ID> durch die globale Metastore-ID des Mitarbeiters, auch bekannt als Freigabebezeichner.

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

Hinweis

Ersetzen Sie den Tabellennamen default.sales durch den angegebenen Tabellennamen.

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