Tisztatéri események rendszerének táblareferenciája

A tiszta szoba eseménytáblája rögzíti az Ön vagy közreműködői által az Ön fiókjában lévő tiszta szobákon végrehajtott műveleteket. Ez a táblázat regionális adatokat tartalmaz a teljes fiókból.

A tiszta szobákról további információt az Azure Databricks Tiszta szobák című témakörben talál.

tábla elérési útja: Ez a rendszertábla a system.access.clean_room_eventstalálható.

Tisztahelyiség eseményrendszer tábla sémája

A tisztaszobás események rendszertáblája a következő sémát használja:

Naplózott tisztatér események

Ez a rendszertábla a következő eseményeket naplózza:

• CLEAN_ROOM_CREATED: A felhasználó új tiszta helyiséget hoz létre.
• CLEAN_ROOM_DELETED: A felhasználó töröl egy tiszta helyiséget.
• RUN_NOTEBOOK_STARTED: A felhasználó elindít egy jegyzetfüzetet, amely tiszta helyiségben fut.
• RUN_NOTEBOOK_COMPLETED: A jegyzetfüzet futtatása befejeződött. Ellenőrizze a run_notebook_completed_metadata, hogy a futtatás sikeres volt-e, vagy nem.
• CLEAN_ROOM_ASSETS_UPDATED: A tiszta helyiség eszközei frissülnek. Ez lehet objektumok hozzáadása, frissítése vagy törlése.
• DELETE_OUTPUT_SCHEMA: A kimeneti séma lejár, és törlődik. Ennek az eseménytípusnak a initiator_global_metastore_id értéke mindig system, mert a törlés akkor következik be, amikor a kimeneti séma lejár.

Az ismétlődő rekordok elkerülése érdekében a rendszer csak egy rekordot bocsát ki minden olyan tiszta helyiségben lévő eseményhez, ahol a közreműködők ugyanahhoz a metaadattárhoz tartoznak. Az olyan tiszta helyiségekben, ahol a közreműködők külön metaadattárakhoz tartoznak, minden közreműködő egyedi rekordokat bocsát ki.

Befejezett metaadat-séma a jegyzetfüzet futtatásához

A run_notebook_completed_metadata oszlop RUN_NOTEBOOK_COMPLETED események metaadatait tartalmazza. Ha a jegyzetfüzet futtatása kimeneti táblát hozott létre, a rendszer a output_schema szerkezettel naplózza az adatokat.

A run_notebook_completed_metadata oszlop a következő sémát használja:

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"

Tiszta helyiség számlázható használatának monitorozása

Ha többet szeretne megtudni a tiszta helyiség használatáról és költségeiről, a billing.usage oszlop használatával összekapcsolhatja ezt a táblázatot a central_clean_room_id táblával. A billing.usage táblában a tiszta helyiség használatát a usage_metadata.central_clean_room_id kulcs segítségével határozzák meg.

Minta lekérdezések

Az alábbi minta lekérdezések segítségével betekintést nyerhet a fiók tiszta helyiségeinek tevékenységébe:

• Sorolja fel a meghatározott tisztaszoba összes eseményét
• Adott közreműködő által kezdeményezett összes esemény listázása
• A tiszta szobák összes érintett közreműködőjének listázása
• A leglassabb jegyzetfüzetfutások listájának megjelenítése
• Sikerességi arány minden jegyzetfüzet esetében
• Felsorolja az összes eseményt, ahol egy adott tábla hozzá lett adva a tiszta helyiségekhez

Adott tiszta helyiség összes eseményének listázása

Cserélje le a :central_clean_room_id-t a központi tisztaszoba-azonosítóra, amely a tisztaszoba részletező paneljén található a Központi azonosítómellett.

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

Egy adott közreműködő által kezdeményezett összes esemény listázása

A :initiator_global_metastore_id paraméterhez adja meg a közreműködő globális metaadattár-azonosítóját, más néven a megosztási azonosítót. :collaborator_aliasesetén adja meg a közreműködő aliasát. Alapértelmezés szerint a két lehetséges alias creator a tiszta szoba létrehozója számára, és collaborator a másik fél számára.

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

A tiszta helyiségek összes érintett közreműködőjének listázása

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'

A leglassabb notebook futásokat sorolja fel

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

Minden egyes jegyzetfüzet sikeres futtatási aránya

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

Azon események listája, ahol egy meghatározott táblát adtak hozzá a tisztaszobákhoz

A :table_name_string paraméterhez adja meg a megadott táblanevet.

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