Temiz oda olayları sistemi table referansı
Önemli
Bu sistem table, Genel Önizlemedurumunda.
table'a erişmek için, schemasystem
içinde catalog etkinleştirilmelidir. Daha fazla bilgi için bkz.Sistem
Temiz oda olayları table, hesabınızdaki temiz odalarda (Genel Önizleme) sizin veya ortak çalışanlarınızın gerçekleştirdiği eylemleri kaydeder. Bu table, hesabınızdaki bölgesel verileri içerir.
Temiz odalar hakkında daha fazla bilgi için bkz . Azure Databricks Clean Rooms nedir?.
Table yol: Bu sistem tablesystem.access.clean_room_events
konumunda bulunur.
Temiz oda olayları sistemi tableschema
Temiz oda olayları sistemi table, aşağıdaki schema'i kullanır:
Column adı | Veri türü | Açıklama | Örnek |
---|---|---|---|
account_id |
Dize | Databricks hesabının kimliği | 7af234db-66d7-4db3 -bbf0-956098224879 |
metastore_id |
Dize | Unity Catalog meta veri deposunun kimliği | 5a31ba44-bbf4-4174 -bf33-e1fa078e6765 |
event_id |
Dize | Temiz oda olayının kimliği | db52a413-7a0a-4d49 -b742-7ae5f06bc4b2 |
clean_room_name |
Dize | Olayla ilişkili temiz odanın adı | market-analysis |
central_clean_room_id |
Dize | Merkezi temiz odanın kimliği | e01b6a78-1336-47e1 -b63d-3e49aa5b627 |
initiator_global_metastore_id |
Dize | Olayı başlatan ortak çalışanın genel meta veri deposu kimliği | aws:us-west-2:ec22936d -cd29-4421-a88a-883fb356776a |
event_time |
timestamp | Olayın gerçekleştiği zaman damgası | 2023-01-01T01:01:01.123 |
event_type |
Dize | Olayın türü. Bkz . Günlüğe kaydedilen temiz oda olayları. | CLEAN_ROOM_CREATED |
clean_room_created_metadata |
struct | Olay türünün meta verileri 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 | Olay türünün meta verileri CLEAN_ROOM_DELETED |
{ "central_clean_room_id": "af0d4563-2267-412c-9d4a -8a59c4895c18" } |
run_notebook_started_metadata |
struct | Olay türünün meta verileri RUN_NOTEBOOK_STARTED |
{ "notebook_name": "market analysis", "notebook_checksum": "7072696E7468656C6C6F776F7264", "run_id": "TaskRunId-634124444694206" } |
run_notebook_completed_metadata |
struct | Olay türünün meta verileri RUN_NOTEBOOK_COMPLETED |
Bkz. Tamamlanan not defteri çalışması meta verileri |
clean_room_assets_updated_metadata |
struct | Olay türünün meta verileri CLEAN_ROOM_ASSETS_UPDATED |
{ "added_assets": [{ "data_object_type": "TABLE", "name": "sales", "catalog": "demo"}], "updated_assets":[], "removed_assets": [] } |
delete_output_schema_metadata |
struct | Olay türünün meta verileri DELETE_OUTPUT_SCHEMA |
{ "name": "output_schema_55555", "owner_global_metastore_id": "aws:us-west-2:555555-55...", "action": "DELETE" expire_time: "2025-01-14T15:28:19.000Z" } |
Günlüğe kaydedilen temiz oda olayları
Bu sistem table 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çinrun_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ış schema süresi dolar ve silinir. Bu olay türününinitiator_global_metastore_id
'ı her zamansystem
'dir, çünkü silme işlemi, çıktı schema sona erdiğinde gerçekleşir.
Tamamlanan not defteri çalıştırma meta verileri schema
run_notebook_completed_metadata
column, RUN_NOTEBOOK_COMPLETED
olayları için meta veri bilgilerini içerir. Not defteri çalıştırması tarafından bir çıktı table oluşturulduysa, bilgiler output_schema
yapısı kullanılarak günlüğe kaydedilir.
run_notebook_completed_metadata
column aşağıdaki schemakullanı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ı izleme
Temiz oda kullanımı ve maliyetleri hakkında daha fazla bilgi edinmek için jointablebilling.usage
ile, tablecentral_clean_room_id
kullanarak bu column yapabilirsiniz.
billing.usage
tabletemiz 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:
- List belirtilen temiz odadan tüm olaylar
- List Belirtilen bir ortak çalışan tarafından başlatılan tüm olayları
- List temiz odaların ilgili tüm ortak çalışanları
- List en yavaş not defteri çalışıyor
- Her not defteri için başarı çalıştırma oranı
- Tüm olaylar List belirtilen wheretable temiz odalara eklendi
Belirtilen temiz odadan List tüm olaylar
Not
değerini, belirttiğiniz temiz oda adıyla değiştirin <clean_room_name>
.
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
Belirtilen bir işbirlikçi tarafından başlatılan tüm olaylar List
:initiator_global_metastore_id
parametresi için, paylaşım identifierolarak da bilinen işbirlikçinin genel meta veri deposu kimliğini girin.
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 = :initiator_global_metastore_id
ORDER BY
clean_room_name,
event_time DESC
Temiz odaların tüm ilgili işbirlikçileri List
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'
List en yavaş dizüstü bilgisayarda çalışır
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ı çalıştırma 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
List tüm olaylar, belirtilen wheretable temiz odalara eklendi
:table_name_string
parametre için, belirttiğiniz table 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