Referenční informace o systému událostí v čistých místnostech table

Důležité

Tento systém table je ve verzi Public Preview. Pro přístup k tablemusí být v schemasystempovolená catalog . Další informace naleznete v tématu Povolení systémových table schémat.

Události čistého prostoru table zaznamenávají akce provedené vámi nebo vašimi spolupracovníky v čistých prostorech (Public Preview) na vašem účtu. Tato table zahrnuje regionální data z celého vašeho účtu.

Další informace o čistých pokojích najdete v tématu Co je Azure Databricks Clean Rooms?.

Table cesta: Tento systém table se nachází v system.access.clean_room_events.

Systém událostí pro čisté prostory tableschema

Systém událostí čistých místností table používá následující schema:

název Column	Datový typ	Popis	Příklad
account_id	string	ID účtu Databricks	7af234db-66d7-4db3 -bbf0-956098224879
metastore_id	string	ID metastoru Unity Catalog	5a31ba44-bbf4-4174 -bf33-e1fa078e6765
event_id	string	ID události čisté místnosti	db52a413-7a0a-4d49 -b742-7ae5f06bc4b2
clean_room_name	string	Název čisté místnosti přidružené k události	market-analysis
central_clean_room_id	string	ID centrální čisté místnosti	e01b6a78-1336-47e1 -b63d-3e49aa5b627
initiator_global_metastore_id	string	ID globálního metastoru spolupracovníka, který událost zahájil	aws:us-west-2:ec22936d -cd29-4421-a88a-883fb356776a
event_time	časové razítko	Časové razítko, kdy došlo k události	2023-01-01T01:01:01.123
event_type	string	Typ události. Viz Protokolované události čisté místnosti.	CLEAN_ROOM_CREATED
clean_room_created_metadata	struct	Metadata typu události 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	Metadata typu události CLEAN_ROOM_DELETED	{ "central_clean_room_id": "af0d4563-2267-412c-9d4a -8a59c4895c18" }
run_notebook_started_metadata	struct	Metadata typu události RUN_NOTEBOOK_STARTED	{ "notebook_name": "market analysis", "notebook_checksum": "7072696E7468656C6C6F776F7264", "run_id": "TaskRunId-634124444694206" }
run_notebook_completed_metadata	struct	Metadata typu události RUN_NOTEBOOK_COMPLETED	Podívejte se na metadata o spuštění poznámkového bloku, která byla dokončena
clean_room_assets_updated_metadata	struct	Metadata typu události CLEAN_ROOM_ASSETS_UPDATED	{ "added_assets": [{ "data_object_type": "TABLE", "name": "sales", "catalog": "demo"}], "updated_assets":[], "removed_assets": [] }
delete_output_schema_metadata	struct	Metadata typu události 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" }

Protokolované události čisté místnosti

Tento systém table protokoluje následující události:

• CLEAN_ROOM_CREATED: Uživatel vytvoří novou čistou místnost.
• CLEAN_ROOM_DELETED: Uživatel odstraní čistou místnost.
• RUN_NOTEBOOK_STARTED: Uživatel zahájí spuštění poznámkového bloku v čisté místnosti.
• RUN_NOTEBOOK_COMPLETED: Je dokončené spuštění poznámkového bloku. Zkontrolujte run_notebook_completed_metadata, abyste ověřili, zda spuštění proběhlo úspěšně nebo ne.
• CLEAN_ROOM_ASSETS_UPDATED: Aktualizují se prostředky čisté místnosti. Může se jednat o přidání, aktualizaci nebo odstranění prostředků.
• DELETE_OUTPUT_SCHEMA: Výstup schema vyprší a poté se odstraní. initiator_global_metastore_id pro tento typ události je vždy system, protože odstranění nastane, když vyprší platnost výstupního schema.

Metadata dokončeného spuštění poznámkového bloku schema

run_notebook_completed_metadata column obsahuje informace o metadatech pro události RUN_NOTEBOOK_COMPLETED. Pokud byl výstup table vytvořen spuštěním poznámkového bloku, informace se protokolují pomocí struktury output_schema.

run_notebook_completed_metadata column používá následující schema:

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"

Monitorování fakturovatelného využití čisté místnosti

Další informace o využití čistých místností a nákladech můžete join tento table s billing.usagetable pomocí central_clean_room_idcolumn. V billing.usagetableje použití čisté místnosti přiřazeno pomocí klíče usage_metadata.central_clean_room_id.

Vzorové dotazy

Následující ukázkové dotazy vám pomůžou získat přehled o aktivitě čisté místnosti ve vašem účtu:

• List všechny události ze zadané čisté místnosti
• List všechny události iniciované zadaným spolupracovníkem
• List všichni relevantní spolupracovníci na čištěných místnostech
• List nejpomalejší notebook běží
• Míra úspěšnosti spuštění pro každý poznámkový blok
• List všechny události where zadané table byly přidány do čistých místností

List všechny události ze zadané čisté místnosti

Poznámka:

Nahraďte <clean_room_name> zadaným názvem čisté místnosti.

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 všechny události iniciované zadaným spolupracovníkem

Jako parametr :initiator_global_metastore_id zadejte ID globálního metastore spolupracovníka, také známé jako sdílení identifier.

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 všichni relevantní spolupracovníci čistých místností

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 nejpomalejší běh notebooku

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

Míra úspěšnosti spuštění pro každý poznámkový blok

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 všechny události where zadané table byly přidány do čistých místností.

Do parametru :table_name_string zadejte zadaný název 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