Referensi tabel sistem acara ruang bersih

Tabel peristiwa ruangan bersih mencatat tindakan yang diambil oleh Anda atau kolaborator Anda di ruang bersih di akun Anda. Tabel ini mencakup data regional dari seluruh akun Anda.

Untuk informasi selengkapnya tentang kamar bersih, lihat Apa itu Azure Databricks Clean Rooms?.

Jalur tabel: Tabel sistem ini terletak di system.access.clean_room_events.

Skema tabel sistem acara ruang bersih

Tabel sistem peristiwa ruangan bersih menggunakan skema berikut:

Peristiwa kamar bersih yang dicatat

Tabel sistem ini mencatat peristiwa berikut:

• CLEAN_ROOM_CREATED: Pengguna membuat ruang bersih baru.
• CLEAN_ROOM_DELETED: Pengguna menghapus ruang bersih.
• RUN_NOTEBOOK_STARTED: Pengguna memulai menjalankan notebook di ruang bersih.
• RUN_NOTEBOOK_COMPLETED: Eksekusi notebook selesai. Periksa run_notebook_completed_metadata untuk melihat apakah eksekusi berhasil atau tidak.
• CLEAN_ROOM_ASSETS_UPDATED: Aset sebuah ruang steril telah diperbarui. Ini bisa menambahkan, memperbarui, atau menghapus aset.
• DELETE_OUTPUT_SCHEMA: Skema output kedaluwarsa dan dihapus. initiator_global_metastore_id untuk jenis peristiwa ini selalu system karena penghapusan terjadi ketika skema output kedaluwarsa.

Untuk mencegah rekaman duplikat, hanya satu rekaman yang dikeluarkan untuk setiap peristiwa di ruang bersih tempat kolaborator termasuk dalam metastore yang sama. Untuk ruang bersih di mana kolaborator berada dalam metastor yang terpisah, catatan unik diterbitkan untuk setiap kolaborator.

Selesai menjalankan skema metadata buku catatan

Kolom run_notebook_completed_metadata berisi informasi metadata untuk peristiwa RUN_NOTEBOOK_COMPLETED. Jika tabel output dibuat oleh notebook run, informasi dicatat menggunakan struct output_schema.

Kolom run_notebook_completed_metadata menggunakan skema berikut:

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"

Memantau penggunaan ruang bersih yang dapat ditagihkan

Untuk mempelajari selengkapnya tentang penggunaan dan biaya kamar yang bersih, Anda dapat menggabungkan tabel ini dengan tabel billing.usage menggunakan kolom central_clean_room_id. Dalam tabel billing.usage, penggunaan ruang steril ditentukan menggunakan kunci usage_metadata.central_clean_room_id.

Contoh kueri

Contoh kueri berikut membantu Anda mendapatkan wawasan tentang aktivitas ruangan yang bersih di akun Anda:

• Daftar semua kejadian dari ruang bersih yang ditentukan
• Mencantumkan semua peristiwa yang dimulai oleh kolaborator tertentu
• Daftar semua para kolaborator yang relevan dari ruang bersih
• Daftarkan jalannya notebook yang paling lambat
• Tingkat keberhasilan pelaksanaan untuk setiap notebook
• Daftar semua peristiwa di mana tabel tertentu ditambahkan ke ruang bersih

Mencantumkan semua peristiwa dari ruang bersih tertentu

Ganti :central_clean_room_id dengan ID pusat ruang bersih, yang dapat ditemukan dalam panel detail ruang bersih di sebelah ID Pusat.

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

Mencantumkan semua peristiwa yang dimulai oleh kolaborator tertentu

Untuk parameter :initiator_global_metastore_id, masukkan ID metastore global kolaborator, yang juga dikenal sebagai pengidentifikasi pembagian. Untuk :collaborator_alias, masukkan alias kolaborator. Secara bawaan, dua alias yang mungkin adalah creator untuk pembuat ruang bersih dan collaborator untuk pihak lainnya.

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

Daftarkan semua kolaborator ruang steril yang relevan

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'

Daftar jalannya notebook yang paling lambat

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

Tingkat eksekusi keberhasilan untuk setiap 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

Daftar semua acara di mana meja tertentu ditambahkan ke ruang bersih

Untuk paramter :table_name_string, masukkan nama tabel yang Anda tentukan.

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