SnowflakeのBillingとコスト管理

Snowflakeの課金はコンピュート（クレジット）とストレージ（TB/月）の2軸で構成されます。 コンピュートはウェアハウスの稼働時間とサーバーレスサービスの使用量に応じてクレジットが消費され、 ストレージはアクティブデータ・Time Travel・Fail-safeの合計容量に対して課金されます。 この記事ではクレジット課金モデルの構造、監視SQL、Resource Monitorの設定、 そして実務で即使えるコスト最適化5策を整理します。

クレジット課金モデル

ウェアハウスサイズとクレジット消費

Multi-cluster Warehouseの場合、上記クレジットにクラスタ数を掛けた値が消費されます。 たとえばMediumサイズで3クラスタ稼働中は 4 × 3 = 12クレジット/時です。

WAREHOUSE_METERING_HISTORY

-- ウェアハウス別の日次クレジット消費
SELECT
  start_time::DATE AS usage_date,
  warehouse_name,
  SUM(credits_used) AS total_credits,
  SUM(credits_used_compute) AS compute_credits,
  SUM(credits_used_cloud_services) AS cloud_credits
FROM SNOWFLAKE.ACCOUNT_USAGE.WAREHOUSE_METERING_HISTORY
WHERE start_time >= DATEADD(MONTH, -1, CURRENT_TIMESTAMP())
GROUP BY 1, 2
ORDER BY total_credits DESC;

-- 時間帯別のクレジット消費パターン分析
SELECT
  EXTRACT(HOUR FROM start_time) AS hour_of_day,
  warehouse_name,
  AVG(credits_used) AS avg_hourly_credits
FROM SNOWFLAKE.ACCOUNT_USAGE.WAREHOUSE_METERING_HISTORY
WHERE start_time >= DATEADD(DAY, -30, CURRENT_TIMESTAMP())
GROUP BY 1, 2
ORDER BY warehouse_name, hour_of_day;

METERING_HISTORY（全サービス統合）

-- 全サービスのクレジット消費を一覧化
SELECT
  start_time::DATE AS usage_date,
  service_type,
  SUM(credits_used) AS total_credits
FROM SNOWFLAKE.ACCOUNT_USAGE.METERING_HISTORY
WHERE start_time >= DATEADD(MONTH, -1, CURRENT_TIMESTAMP())
GROUP BY 1, 2
ORDER BY usage_date, total_credits DESC;

-- service_type の値:
-- WAREHOUSE_METERING    : ウェアハウス
-- AUTO_CLUSTERING       : Automatic Clustering
-- MATERIALIZED_VIEW     : MV メンテナンス
-- PIPE                  : Snowpipe
-- REPLICATION           : レプリケーション
-- SEARCH_OPTIMIZATION   : Search Optimization Service
-- SERVERLESS_TASK       : Serverless Task

Resource Monitor

Resource Monitorは、ウェアハウスのクレジット消費に上限を設定し、 閾値到達時に通知・サスペンドを行うガバナンス機能です。 ACCOUNTADMINロールで作成・管理します。

-- Resource Monitorの作成
CREATE RESOURCE MONITOR bi_monitor
  WITH CREDIT_QUOTA = 500
  FREQUENCY = MONTHLY
  START_TIMESTAMP = IMMEDIATELY
  TRIGGERS
    ON 80 PERCENT DO NOTIFY
    ON 95 PERCENT DO SUSPEND
    ON 100 PERCENT DO SUSPEND_IMMEDIATE;

-- ウェアハウスにResource Monitorを割り当て
ALTER WAREHOUSE bi_dashboard_wh SET RESOURCE_MONITOR = bi_monitor;

-- アカウントレベルのResource Monitor（全ウェアハウスに適用）
ALTER ACCOUNT SET RESOURCE_MONITOR = account_monitor;

-- Resource Monitorの確認
SHOW RESOURCE MONITORS;

Resource Monitorのアクション比較

コスト最適化5策

1. AUTO_SUSPENDの適正化

-- 対話型: 5分（300秒）で自動サスペンド
ALTER WAREHOUSE bi_wh SET AUTO_SUSPEND = 300;

-- バッチ: 1分（60秒）で自動サスペンド
ALTER WAREHOUSE etl_wh SET AUTO_SUSPEND = 60;

-- AUTO_RESUME を有効にしてクエリ受信時に自動再開
ALTER WAREHOUSE bi_wh SET AUTO_RESUME = TRUE;

2. ウェアハウスのワークロード分離

BI・ETL・データサイエンスなど異なるワークロードを同一ウェアハウスで実行すると、 リソース競合によりすべてのクエリが遅くなり、結果的にコスト増大につながります。 ワークロードごとに専用ウェアハウスを作成し、適切なサイズとAUTO_SUSPEND設定を個別に行います。

3. クエリ最適化によるスキャン量削減

-- パーティションプルーニング効率が低いクエリの特定
SELECT
  query_id,
  query_text,
  partitions_scanned,
  partitions_total,
  ROUND(partitions_scanned / NULLIF(partitions_total, 0) * 100, 1) AS scan_pct,
  bytes_scanned / POWER(1024, 3) AS gb_scanned
FROM SNOWFLAKE.ACCOUNT_USAGE.QUERY_HISTORY
WHERE start_time >= DATEADD(DAY, -7, CURRENT_TIMESTAMP())
  AND partitions_total > 100
  AND partitions_scanned / NULLIF(partitions_total, 0) > 0.8
ORDER BY bytes_scanned DESC
LIMIT 20;

4. ストレージコストの削減

-- Time TravelとFail-safeのストレージ使用量を確認
SELECT
  table_catalog AS database_name,
  table_schema AS schema_name,
  table_name,
  ROUND(active_bytes / POWER(1024, 3), 2) AS active_gb,
  ROUND(time_travel_bytes / POWER(1024, 3), 2) AS time_travel_gb,
  ROUND(failsafe_bytes / POWER(1024, 3), 2) AS failsafe_gb,
  ROUND(retained_for_clone_bytes / POWER(1024, 3), 2) AS clone_gb
FROM SNOWFLAKE.ACCOUNT_USAGE.TABLE_STORAGE_METRICS
WHERE active_bytes > 0
ORDER BY (active_bytes + time_travel_bytes + failsafe_bytes) DESC
LIMIT 30;

-- 不要なTransientテーブルの検出（Fail-safeが不要な中間データ）
-- Transientテーブルに切り替えることでFail-safeストレージコストを削減

5. Serverless Creditの監視と制御

-- Serverlessサービス別のクレジット消費トレンド
SELECT
  start_time::DATE AS usage_date,
  service_type,
  SUM(credits_used) AS credits
FROM SNOWFLAKE.ACCOUNT_USAGE.METERING_HISTORY
WHERE start_time >= DATEADD(MONTH, -1, CURRENT_TIMESTAMP())
  AND service_type != 'WAREHOUSE_METERING'
GROUP BY 1, 2
ORDER BY usage_date, credits DESC;

チャージバックレポート

-- ウェアハウス別の月次コストレポート（チャージバック用）
SELECT
  warehouse_name,
  DATE_TRUNC('MONTH', start_time) AS billing_month,
  SUM(credits_used) AS total_credits,
  SUM(credits_used) * 3.00 AS estimated_cost_usd  -- 単価は契約による
FROM SNOWFLAKE.ACCOUNT_USAGE.WAREHOUSE_METERING_HISTORY
WHERE start_time >= DATEADD(MONTH, -3, CURRENT_TIMESTAMP())
GROUP BY 1, 2
ORDER BY billing_month DESC, total_credits DESC;

問題で確認

よくある質問