거버넌스 비교

Account Level
  └─ Unity Catalog Metastore (리전별 1개)
      ├─ Catalog: prod
      │   ├─ Schema: sales
      │   │   ├─ Table: orders (Delta Lake)
      │   │   ├─ View: v_monthly_revenue
      │   │   ├─ Function: calculate_tax()
      │   │   └─ Volume: raw_files (PDF, 이미지)
      │   ├─ Schema: ml_models
      │   │   ├─ Model: churn_predictor (v1, v2, v3)
      │   │   ├─ Feature Table: customer_features
      │   │   └─ Vector Search Index: doc_embeddings
      │   └─ Schema: agents
      │       ├─ Agent: customer_support_agent
      │       └─ Function: search_knowledge_base()  ← Agent 도구
      ├─ Catalog: dev
      ├─ Catalog: staging
      └─ External Connections
          ├─ PostgreSQL (외부 DB)
          ├─ Snowflake (연합 쿼리)
          └─ MySQL (외부 DB)

-- Row Filter: 사용자 부서에 해당하는 행만 조회
CREATE FUNCTION catalog.schema.region_filter(region STRING)
RETURN IF(IS_ACCOUNT_GROUP_MEMBER('admin'), true, region = CURRENT_USER_ATTRIBUTE('department'));

ALTER TABLE catalog.schema.sales SET ROW FILTER catalog.schema.region_filter ON (region);

-- Column Mask: PII 데이터 동적 마스킹
CREATE FUNCTION catalog.schema.mask_email(email STRING)
RETURN IF(IS_ACCOUNT_GROUP_MEMBER('pii_viewer'), email, REGEXP_REPLACE(email, '(.).*@', '$1***@'));

ALTER TABLE catalog.schema.customers ALTER COLUMN email SET MASK catalog.schema.mask_email;

-- 워크스페이스별 일별 비용 추이
SELECT
  date_trunc('day', usage_date) AS day,
  workspace_id,
  sku_name,
  SUM(usage_quantity * list_price) AS estimated_cost
FROM system.billing.usage u
JOIN system.billing.list_prices p ON u.sku_name = p.sku_name
WHERE usage_date >= date_sub(current_date(), 30)
GROUP BY 1, 2, 3
ORDER BY 1;

-- 비정상 비용 알림 (이전 주 대비 50% 이상 증가)
WITH weekly_cost AS (
  SELECT
    date_trunc('week', usage_date) AS week,
    SUM(usage_quantity * list_price) AS cost
  FROM system.billing.usage u
  JOIN system.billing.list_prices p ON u.sku_name = p.sku_name
  GROUP BY 1
)
SELECT *
FROM weekly_cost
WHERE cost > LAG(cost) OVER (ORDER BY week) * 1.5;