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 system.access.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: Ein Clean Room wird manuell gelöscht.
• RUN_NOTEBOOK_STARTED: Der Benutzer initiiert die Ausführung eines Notizbuchs 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 oder nicht.
• 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.
• DELETE_OUTPUT_SCHEMA: Ein Ausgabeschema läuft ab und wird gelöscht. Der initiator_global_metastore_id für diesen Ereignistyp ist immer system, weil der Löschvorgang auftritt, wenn das Ausgabeschema abgelaufen ist.

Um doppelte Datensätze zu verhindern, wird nur ein Datensatz für jedes Ereignis in Clean Rooms ausgegeben, in denen die Mitwirkenden zum gleichen Metaspeicher gehören. Für Reinräume, in denen Mitwirkende zu separaten Metastores gehören, werden eindeutige Datensätze für jede mitwirkende Person ausgegeben.

Metadatenschema des abgeschlossenen Notizbuchdurchlaufs

Die Spalte run_notebook_completed_metadata enthält Metadateninformationen für RUN_NOTEBOOK_COMPLETED Ereignisse. Wenn eine Ausgabetabelle durch die Ausführung des Notizbuchs erstellt wurde, werden die Informationen mithilfe der output_schema-Struktur protokolliert.

Die spalte run_notebook_completed_metadata verwendet das folgende Schema:

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"

Ü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

Ersetzen Sie :central_clean_room_id durch die zentrale Reinraum-ID, die sich im Detailbereich des Reinraums neben der Zentral-IDbefindet.

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

Auflisten aller Ereignisse, die von einem angegebenen Mitarbeiter initiiert wurden

Geben Sie für den :initiator_global_metastore_id-Parameter die globale Metastore-ID (auch „Freigabe-ID“) der mitarbeitenden Person ein. Geben Sie für :collaborator_aliasden Alias des Mitarbeiters ein. Standardmäßig sind die beiden möglichen Aliasnamen creator für den Ersteller des Reinraums und collaborator für die andere Partei.

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

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

Geben Sie für den :table_name_string Paramter den angegebenen Tabellennamen ein.

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