Udostępnij za pośrednictwem

System zdarzeń w czystym pomieszczeniu table – odniesienie

  • Artykuł

Ważne

Ten system table znajduje się w publicznej wersji zapoznawczej. Aby uzyskać dostęp do table, schema musi być włączona w systemcatalog. Aby uzyskać więcej informacji, zobacz Włącz schematy systemowe table.

Zdarzenia dotyczące czystych pomieszczeń table rejestrują działania podejmowane przez Ciebie i Twoich współpracowników w czystych pomieszczeniach (wersja publiczna wstępna) na Twoim koncie. Ten table zawiera regionalne dane z całego twojego konta.

Aby uzyskać więcej informacji na temat czystych pomieszczeń, zobacz Co to jest usługa Azure Databricks Clean Rooms?.

Table ścieżka: ten system table znajduje się pod adresem system.access.clean_room_events.

System zdarzeń czystego pokoju tableschema

System zdarzeń w pomieszczeniu czystym table używa następujących schema:

nazwa Column Typ danych opis Przykład
account_id string Identyfikator konta usługi Databricks 7af234db-66d7-4db3

-bbf0-956098224879
metastore_id string Identyfikator magazynu metadanych Unity Catalog 5a31ba44-bbf4-4174

-bf33-e1fa078e6765
event_id string Identyfikator zdarzenia w pomieszczeniu czystego pokoju db52a413-7a0a-4d49

-b742-7ae5f06bc4b2
clean_room_name string Nazwa czystego pokoju skojarzonego ze zdarzeniem market-analysis
central_clean_room_id string Identyfikator centralnego czystego pokoju e01b6a78-1336-47e1

-b63d-3e49aa5b627
initiator_global_metastore_id string Globalny identyfikator magazynu metadanych współpracownika, który zainicjował zdarzenie aws:us-west-2:ec22936d

-cd29-4421-a88a-883fb356776a
event_time timestamp Sygnatura czasowa zdarzenia 2023-01-01T01:01:01.123
event_type string Typ zdarzenia. Zobacz Zarejestrowane zdarzenia w pokoju. CLEAN_ROOM_CREATED
clean_room_created_metadata struktura Metadane typu zdarzenia 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 struktura Metadane typu zdarzenia CLEAN_ROOM_DELETED {

"central_clean_room_id": "af0d4563-2267-412c-9d4a

-8a59c4895c18"

}
run_notebook_started_metadata struktura Metadane typu zdarzenia RUN_NOTEBOOK_STARTED {

"notebook_name": "market analysis",

"notebook_checksum": "7072696E7468656C6C6F776F7264",

"run_id": "TaskRunId-634124444694206"

}
run_notebook_completed_metadata struktura Metadane typu zdarzenia RUN_NOTEBOOK_COMPLETED {

"notebook_name": "market analysis",

"run_id": "TaskRunId-634124444694206",

"state": "SUCCESS",

"duration_in_seconds": 156

}
clean_room_assets_updated_metadata struktura Metadane typu zdarzenia CLEAN_ROOM_ASSETS_UPDATED {

"added_assets": [{

"data_object_type": "TABLE",

"name": "sales",

"catalog": "demo"}],

"updated_assets":[],

"removed_assets": []

}

Zarejestrowane zdarzenia w pomieszczeniu czyste

Ten system table rejestruje następujące zdarzenia:

  • CLEAN_ROOM_CREATED: Użytkownik tworzy nowy pokój czysty
  • CLEAN_ROOM_DELETED: Użytkownik usuwa czysty pokój
  • RUN_NOTEBOOK_STARTED: Użytkownik uruchamia notatnik w czystym pomieszczeniu
  • RUN_NOTEBOOK_COMPLETED: Ukończono uruchamianie notesu. Sprawdź run_notebook_completed_metadata, aby sprawdzić, czy przebieg zakończył się pomyślnie, czy nie.
  • CLEAN_ROOM_ASSETS_UPDATED: Zasoby czystego pokoju są aktualizowane. Może to być dodawanie, aktualizowanie lub usuwanie zasobów.

Monitorowanie rozliczanego użycia pomieszczeń czystych

Aby dowiedzieć się więcej na temat używania i kosztów pomieszczeń typu clean room, możesz jointable z billing.usagetable przy użyciu central_clean_room_idcolumn. W billing.usagetableużycie czystych pomieszczeń jest przypisywane za pomocą klucza usage_metadata.central_clean_room_id.

Przykładowe zapytania

Następujące przykładowe zapytania ułatwiają uzyskanie wglądu w aktywność pomieszczeń czystych na koncie:

List wszystkich zdarzeń z określonego czystego pokoju

Uwaga

Zastąp <clean_room_name> wartość określoną nazwą czystego pokoju.

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

List wszystkie zdarzenia zainicjowane przez określonego współpracownika

W przypadku parametru :initiator_global_metastore_id wprowadź globalny identyfikator magazynu metadanych współpracownika, znany również jako identifierdo udostępniania.

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

List wszystkich odpowiednich współpracowników stref czystych

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 najwolniejszy notebook działa

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

Współczynnik przebiegów powodzenia dla każdego notesu

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 wszystkie zdarzenia wheretable zostały dodane do czystych pomieszczeń

W przypadku paramteru :table_name_string wprowadź określoną nazwę table.

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