Temiz oda olayları sistem tablosu referansı

Temiz oda olayları tablosu, sizin veya ortak çalışanlarınızın hesabınızdaki temiz odalar üzerinde gerçekleştirdiği eylemleri kaydeder. Bu tablo, hesabınızdaki bölgesel verileri içerir.

Temiz odalar hakkında daha fazla bilgi için bkz . Azure Databricks Clean Rooms nedir?.

Tablo yolu: Bu sistem tablosu system.access.clean_room_eventskonumunda bulunur.

Temiz oda olayları sistem tablosu şeması

Temiz oda olayları sistem tablosu aşağıdaki şemayı kullanır:

Günlüğe kaydedilen temiz oda olayları

Bu sistem tablosu aşağıdaki olayları günlüğe kaydeder:

• CLEAN_ROOM_CREATED: Kullanıcı yeni bir temiz oda oluşturur.
• CLEAN_ROOM_DELETED: Kullanıcı temiz bir odayı siler.
• RUN_NOTEBOOK_STARTED: Kullanıcı temiz bir odada bir not defteri çalıştırması başlatır.
• RUN_NOTEBOOK_COMPLETED: Not defteri çalıştırması tamamlandı. Çalıştırmanın başarılı olup olmadığını görmek için run_notebook_completed_metadata'ı kontrol edin.
• CLEAN_ROOM_ASSETS_UPDATED: Temiz bir odanın varlıkları güncelleştirilir. Bu, varlıkları ekleme, güncelleştirme veya silme olabilir.
• DELETE_OUTPUT_SCHEMA: Çıkış şemasının süresi dolar ve silinir. Bu olay türü için initiator_global_metastore_id her zaman system'dir çünkü silme işlemi, çıktı şemasının süresi dolduğunda gerçekleşir.

Yinelenen kayıtları önlemek için, ortak çalışanların aynı meta veri deposuna ait olduğu temiz odalardaki her olay için yalnızca bir kayıt yayılır. Ayrı meta depolara ait olan ortak çalışanların bulunduğu temiz alanlar için, her bir ortak çalışan için benzersiz kayıtlar oluşturulur.

Tamamlanan not defteri çalıştırma meta veri şeması

run_notebook_completed_metadata sütunu, RUN_NOTEBOOK_COMPLETED olayları için meta veri bilgilerini içerir. Not defteri çalıştırması tarafından bir çıkış tablosu oluşturulduysa, bilgiler output_schema yapısı kullanılarak kayıt altına alınır.

run_notebook_completed_metadata sütunu aşağıdaki şemayı kullanır:

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"

Temiz oda faturalanabilir kullanımını izleyin

Temiz oda kullanımı ve maliyetleri hakkında daha fazla bilgi edinmek için billing.usage sütununu kullanarak bu tabloyu central_clean_room_id tablosuyla birleştirebilirsiniz. billing.usage tablosunda temiz oda kullanımı, usage_metadata.central_clean_room_id anahtarı kullanılarak ilişkilendirilir.

Örnek sorgular

Aşağıdaki örnek sorgular, hesabınızdaki temiz oda etkinliği hakkında içgörü kazanmanıza yardımcı olur:

• Belirtilen temiz bir odadan gelen tüm olayları listele
• Belirtilen bir ortak çalışan tarafından başlatılan tüm olayları listele
• Temiz odaların tüm ilgili ortak çalışanlarını listele
• En yavaş not defteri çalışmaları listesini oluştur
• Her bir notebook için başarı oranı
• Belirtilen bir tablonun temiz odalara eklendiği tüm olayları listele

Belirtilen temiz odadan gelen tüm olayları listeleme

:central_clean_room_id'yi merkezi temiz oda kimliğiyle değiştirin; bu kimlik, temiz odanın detay panelinde Merkez Kimliği'nin yanında bulunabilir.

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

Belirtilen bir ortak çalışan tarafından başlatılan tüm olayları listeleme

:initiator_global_metastore_id parametresi için ortak çalışanın paylaşım tanımlayıcısı olarak da bilinen genel meta veri deposu kimliğini girin. :collaborator_aliasiçin iş arkadaşının takma adını girin. Varsayılan olarak, iki olası takma ad temiz odanın oluşturucusu için creator ve diğer taraf için collaborator'dir.

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

Temiz odaların tüm ilgili işbirlikçilerini listele

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'

En yavaş not defteri çalıştırmalarını listele

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

Her not defteri için başarı oranı

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

Belirtilen bir tablonun temiz odalara eklendiği tüm olayları listeleme

:table_name_string parametre için, belirttiğiniz tablo adını girin.

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