Query Profileの使い方｜Snowflakeクエリパフォーマンス分析

Query Profileは、Snowflakeのクエリ実行計画と実行統計を視覚的に確認できるパフォーマンス分析ツールです。 SnowsightのUIでオペレーターごとの処理時間・スキャンしたパーティション数・Spill量を確認し、ボトルネックを特定できます。

この記事では、Snowsight UIでのQuery Profileの見方・Most Expensive Nodesの特定方法・パーティションプルーニングの確認・Spill分析・ボトルネック特定フローを解説します。SnowPro試験のPerformance Conceptsドメインで頻出するトピックです。

Query Profileへのアクセス方法

Query ProfileはSnowsight（WebUI）で確認します。

1. Snowsightの左メニューから「Activity」→「Query History」を開く
2. 分析対象のクエリを検索してクリック
3. 「Query Profile」タブを選択するとDAGビュー（有向非巡回グラフ）が表示される

WorksheetでSQLを実行した場合は、結果タブの横にある「Query Profile」リンクから直接アクセスできます。SQLでQuery Profileの統計情報を取得するにはGET_QUERY_OPERATOR_STATS()テーブル関数を使用します。

-- SQLでQuery Profileの統計情報を取得
SELECT *
FROM TABLE(GET_QUERY_OPERATOR_STATS('01b2c3d4-0001-abcd-0000-00012345abcd'));

DAGビューの構成要素

Query Profileは各処理をオペレーター（ノード）として表示し、データの流れを矢印で接続したDAG（有向非巡回グラフ）として表現します。

Most Expensive Nodesの特定

Snowsightではクエリ全体の処理時間に対する各ノードの占有率をパーセンテージで表示し、最もリソースを消費したノードを色付きで強調表示します。

ボトルネックの原因パターン

パーティションプルーニングの確認

パーティションプルーニングは、WHERE句の条件に基づいて不要なマイクロパーティションの読み取りをスキップする最適化です。Query ProfileのTableScanオペレーターで以下の値を確認します。

• Partitions Total — テーブル全体のパーティション数
• Partitions Scanned — 実際にスキャンしたパーティション数

Partitions Scanned / Partitions Totalの比率が低いほどプルーニングが効いています。比率が100%に近い場合、クラスタリングキーの設定が効果的です。

-- プルーニング効果の確認例
-- WHERE句のカラムにクラスタリングキーを設定
ALTER TABLE large_events CLUSTER BY (event_date);

-- クラスタリング状態の確認
SELECT SYSTEM$CLUSTERING_INFORMATION('large_events', '(event_date)');

Spill分析

Spillは、クエリ実行時にメモリに収まりきらないデータがディスクに書き出される現象で、パフォーマンス劣化の主要原因です。

Query Profileの各オペレーターでBytes Spilled to Local StorageとBytes Spilled to Remote Storageの値を確認します。Remote Spillが発生している場合は、Warehouseのサイズアップが最優先の対処法です。

ボトルネック特定フロー

1. Query Profileを開く — SnowsightのQuery HistoryまたはWorksheetから対象クエリを選択
2. Most Expensive Nodesを確認 — DAGビューで色付きで強調されたノードを特定
3. Spillの有無を確認 — Bytes Spilled to Local/Remote Storageが0でないか確認
4. パーティションプルーニングを確認 — TableScanのPartitions Scanned vs Total比率をチェック
5. 対策を実施 — サイズアップ・クラスタリングキー設定・クエリ最適化のいずれかを適用
6. 改善を確認 — 同じクエリを再実行してQuery Profileで改善を確認

SQLによるクエリ分析

-- 直近24時間で実行時間が長いクエリ上位10件
SELECT query_id, query_text, total_elapsed_time / 1000 AS elapsed_sec,
       bytes_spilled_to_local_storage, bytes_spilled_to_remote_storage,
       partitions_scanned, partitions_total
FROM snowflake.account_usage.query_history
WHERE start_time > DATEADD(hour, -24, CURRENT_TIMESTAMP())
  AND execution_status = 'SUCCESS'
ORDER BY total_elapsed_time DESC
LIMIT 10;

問題例

よくある質問（FAQ）