Referentie van de tabel voor het systeem van cleanroom-gebeurtenissen

De tabel met clean room-gebeurtenissen registreert acties die u of uw medewerkers in clean rooms in uw account hebben uitgevoerd. Deze tabel bevat regionale gegevens uit uw account.

Zie Wat is Azure Databricks Clean Rooms? voor meer informatie over schone ruimten.

tabelpad: deze systeemtabel bevindt zich op system.access.clean_room_events.

Schema van systeemtabel voor clean room events

De clean room events-systeemtabel heeft het volgende schema:

Vastgelegde gebeurtenissen in cleanrooms

In deze systeemtabel worden de volgende gebeurtenissen geregistreerd:

• CLEAN_ROOM_CREATED: Gebruiker maakt een nieuwe schone ruimte.
• CLEAN_ROOM_DELETED: Gebruiker verwijdert een schone ruimte.
• RUN_NOTEBOOK_STARTED: Gebruiker start een notebooksessie in een schone ruimte.
• RUN_NOTEBOOK_COMPLETED: Een notebookuitvoering is voltooid. Controleer de run_notebook_completed_metadata om te zien of de uitvoering is geslaagd of niet.
• CLEAN_ROOM_ASSETS_UPDATED: De assets van een schone ruimte worden bijgewerkt. Dit kan het toevoegen, bijwerken of verwijderen van assets zijn.
• OUTPUT_SCHEMA_DELETED: een uitvoerschema verloopt en wordt verwijderd. De initiator_global_metastore_id van dit type gebeurtenis is altijd system omdat het verwijderen gebeurt wanneer het uitvoerschema verloopt.
• ASSET_REVIEW_CREATED: Gebruiker beoordeelt een cleanroomvoorziening. Dit kan door het systeem gegenereerde beoordelingen zijn namens de gebruiker.

Om dubbele records te voorkomen, wordt er slechts één record verzonden voor elke gebeurtenis in clean rooms waar de medewerkers deel uitmaken van dezelfde metastore. Voor schone ruimten waar medewerkers deel uitmaken van afzonderlijke metastores, worden unieke records uitgegeven voor elke medewerker.

Voltooid metagegevensschema voor notebookuitvoering

De kolom run_notebook_completed_metadata bevat metagegevensinformatie voor RUN_NOTEBOOK_COMPLETED gebeurtenissen. Als een uitvoertabel door de notebookuitvoering is gemaakt, wordt de informatie vastgelegd met behulp van de struct output_schema.

In de kolom run_notebook_completed_metadata wordt het volgende schema gebruikt:

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"

Cleanroom asset review gebeurtenissen

De systeemtabel registreert metagegevens over controleacties, zoals goedkeuringen, afwijzingen en automatische goedkeuringen die worden uitgevoerd op afzonderlijke clean room-assets. De verschillende beoordelingstypen retourneren de volgende structs:

Goedkeuring:

{
  "asset_name": "Market Analysis",
  "data_object_type": "NOTEBOOK_FILE",
 "notebook_metadata: {
    “etag": "f2429adc02d548bacc11db6c8891ec2548d38b4798a80810fbc8be784af22931",
  }
  "review_state": "APPROVED",
  "review_subreason": null,
  "auto_approval_rule_id": null,
}

Afwijzing:

{
  "asset_name": "Market Analysis",
  "data_object_type": "NOTEBOOK_FILE",
 "notebook_metadata: {
    “etag": "f2429adc02d548bacc11db6c8891ec2548d38b4798a80810fbc8be784af22931",
  }
  "review_state": "REJECTED",
  "review_subreason": null,
  "auto_approval_rule_id": null,
}

Automatische goedkeuring:

{
  "asset_name": "Market Analysis",
  "data_object_type": "NOTEBOOK_FILE",
 "notebook_metadata: {
    “etag": "f2429adc02d548bacc11db6c8891ec2548d38b4798a80810fbc8be784af22931",
  }
  "review_state": "APPROVED",
  "review_subreason": "AUTO_APPROVED",
  "auto_approval_rule_id": "d0ec563f-6d58-4f38-99c0-376b779e3747",
}

Controleer het factureerbare gebruik van de schone ruimte

Voor meer informatie over het gebruik en de kosten van een schone ruimte kunt u deze tabel samenvoegen met de billing.usage tabel met behulp van de kolom central_clean_room_id. In de billing.usage tabel wordt het cleanroomgebruik toegeschreven met behulp van de usage_metadata.central_clean_room_id sleutel.

Voorbeeldqueries

Met de volgende voorbeeldquery's krijgt u inzicht in de activiteiten van de clean room in uw account:

• Alle gebeurtenissen uit een opgegeven clean room weergeven
• alle gebeurtenissen weergeven die zijn geïnitieerd door een opgegeven samenwerker
• Lijst alle relevante samenwerkingspartners van de cleanrooms
• Geef een lijst van de traagste notebook-uitvoeringen
• Succesuitvoeringspercentage voor elk notebook
• Som alle gebeurtenissen op waarin een specifieke tabel is toegevoegd aan clean rooms

Alle gebeurtenissen uit een opgegeven schone ruimte weergeven

Vervang :central_clean_room_id door de centrale cleanroom-ID, die te vinden is in het detailpaneel van de cleanroom naast Central Id.

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)
   WHEN event_type = 'OUTPUT_SCHEMA_DELETED' THEN to_json(output_schema_deleted_metadata)
   WHEN event_type = 'ASSET_REVIEW_CREATED' THEN to_json(asset_review_created_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

Alle gebeurtenissen weergeven die zijn geïnitieerd door een opgegeven samenwerker

Voer voor de :initiator_global_metastore_id parameter de globale metastore-identificatie van de samenwerker in, ook wel de deelidentificatie genoemd. Voer :collaborator_aliasde alias van de samenwerker in. Standaard zijn de twee mogelijke aliassen creator voor de maker van de schone ruimte en collaborator voor de andere partij.

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)
   WHEN event_type = 'OUTPUT_SCHEMA_DELETED' THEN to_json(output_schema_deleted_metadata)
   WHEN event_type = 'ASSET_REVIEW_CREATED' THEN to_json(asset_review_created_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

Alle relevante samenwerkingspartners van de cleanrooms vermelden

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'

De traagste notebook-runs weergeven

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

Succesuitvoeringspercentage voor elk 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

Lijst alle gebeurtenissen op waarin een opgegeven tabel is toegevoegd aan cleanrooms

Voer de opgegeven tabelnaam in voor de :table_name_string paramter.

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