Snowflake

SnowPro Advanced: Data Engineer

2026-03-26
更新: 2026-10-15
NicheeLab編集部
目次
  1. 試験概要
  2. 出題ドメインと配点
  3. Streams & Tasks
  4. Snowpipe & Snowpipe Streaming
  5. Dynamic Tables
  6. Semi-structured Data
  7. パフォーマンス最適化のポイント
  8. 学習戦略
  9. データ保護のポイント
  10. 問題で確認
  11. よくある質問

SnowPro Advanced: Data Engineer Certificationは、Snowflake上でのデータパイプライン構築・最適化・運用管理に関する高度な知識を証明する試験です。 Streams/Tasks/Snowpipe/Dynamic Tables/Semi-structured Dataなど、データエンジニアリングの実務に直結するトピックが中心です。 本記事では試験概要、出題ドメイン、各トピックの学習ポイント、合格戦略を解説します。

試験概要

項目詳細
試験コードDEA-C02
問題数65問(単一選択・複数選択・Interactive)
試験時間115分
合格ライン750点 / 1000点満点
受験料$375 USD
前提条件SnowPro Core認定(有効期間内)
受験方法Pearson VUE(テストセンター or オンライン)
認定有効期間2年間
推奨経験Snowflakeでのデータエンジニアリング実務2年以上

出題ドメインと配点

英語版の公式試験ページとStudy Guide(DEA-C02、2026年3月6日更新)に載っている出題分野は次の5つです。

ドメイン配点主要トピック
データ移動(1.0 Data Movement)28%データのロードと取り込み(ファイル形式・INFER_SCHEMA・ステージとストレージ統合)、取り込みエラーの調査、継続的なパイプライン(Snowpipe・Snowpipe Streaming・Streams・Tasks・Dynamic Tables)、コネクタ(Kafka・Spark・Python)、データ共有とMarketplace、外部テーブル・Icebergテーブル・ハイブリッドテーブル
パフォーマンスの最適化(2.0 Performance Optimization)19%パフォーマンスの悪いクエリの調査、ウェアハウスの設定(スケールアップとスケールアウト・マルチクラスター・Snowpark-optimized)、クラスタリング・マテリアライズドビュー・検索最適化・Query Acceleration・キャッシュ、ACCOUNT_USAGEとResource Monitor、継続的なパイプラインの監視(タスク履歴・アラート・データ品質)
ストレージとデータ保護(3.0 Storage and Data Protection)14%Time Travel(Streamsへの影響)・Fail-safe、リージョンやクラウドをまたぐレプリケーション、システム関数によるマイクロパーティションの分析(クラスタリングの深さ・クラスタリングキー)、Time Travelとクローンを使った開発環境の作成
データガバナンス(4.0 Data Governance)14%オブジェクトのタグ付けとデータ分類、データリネージ、データ品質の監視、列レベルセキュリティ(Dynamic Data Masking・外部トークン化)、行アクセス・射影・集計ポリシー、Data Clean Rooms
データ変換(5.0 Data Transformation)25%UDF(Snowpark・SQL・JavaScript、UDTF・UDAF)と外部関数、ストアドプロシージャとトランザクション、半構造化データと非構造化データの処理(ディレクトリテーブル)、Snowflake Cortexの機能、Snowparkでのデータ変換、Notebooks・Git連携・dbt Projectsを使った開発ワークフロー

日本語版の試験ページとStudy Guideは、2026年10月時点で以前の配点(データ移動26%・パフォーマンスの最適化21%、ほかの3分野は同じ)のままです。

Streams & Tasks

StreamsはSnowflakeのChange Data Capture(CDC)機能で、テーブルに対するINSERT/UPDATE/DELETE操作を追跡します。 Tasksと組み合わせることで、スケジュールベースのデータパイプラインを構築できます。

Streamの種類追跡対象用途
StandardINSERT / UPDATE / DELETE一般的なCDC
Append-onlyINSERTのみ追加専用テーブル(ログ・イベント)
Insert-only(External Tables用)新規ファイル追加External Tableの新ファイル検出

Tasksはスケジュール(CRON式 or 分単位)またはStreamのデータ有無(SYSTEM$STREAM_HAS_DATA)をトリガーにSQLを実行します。 タスクツリーとして親子関係を定義し、DAG(有向非巡回グラフ)形式のパイプラインを構成できます。

Snowpipe & Snowpipe Streaming

Snowpipeはステージ上のファイル到着を検知して自動的にCOPY INTOを実行するサーバーレスのデータ取り込み機能です。

  • Auto-ingest Snowpipe:クラウドイベント通知(AWS SQS / Azure Event Grid / GCS Pub/Sub)をトリガーに自動取り込み
  • REST API Snowpipe:insertFiles REST APIを呼び出して手動トリガー
  • Snowpipe Streaming:Snowflake Ingest SDKを使ったロー・レベルのストリーミング取り込み(ファイル不要・低レイテンシ)
比較項目Auto-ingest SnowpipeSnowpipe Streaming
トリガーファイル到着イベントSDK API呼び出し
レイテンシ1〜数分数秒
ファイル必要性必要(Stage上のファイル)不要(行単位で挿入)
課金モデルサーバーレスクレジットサーバーレスクレジット

Dynamic Tables

Dynamic TablesはSnowflakeで宣言的にデータパイプラインを定義する機能です。 ターゲットテーブルをSQLクエリで定義すると、ソースデータの変更に応じて自動的に更新されます。

  • TARGET_LAGパラメータで更新頻度を制御(例: 1 MINUTE / 1 HOUR / DOWNSTREAM)
  • DOWNSTREAMを指定すると、下流のDynamic Tableのラグに合わせて更新
  • 複数のDynamic Tablesを連鎖させてメダリオンアーキテクチャ(Bronze → Silver → Gold)を構築可能
  • Streams + Tasksと比較して、パイプラインの定義・保守がシンプル

Semi-structured Data

SnowflakeはJSON・XML・Avro・Parquet・ORCなどの半構造化データをVARIANT型で格納し、SQLでクエリできます。

  • 格納:VARIANT / OBJECT / ARRAY 型にPARSE_JSONで変換して格納
  • アクセス:ドット記法(col:key)またはブラケット記法(col['key'])
  • 展開:FLATTEN関数 + LATERAL JOINでネスト配列を行に展開
  • スキーマ検出:INFER_SCHEMA関数でステージ上のファイルからスキーマを自動推定
  • 型変換:::演算子でVARIANT内の値を指定型にキャスト(例: col:price::NUMBER)

パフォーマンス最適化のポイント

手法適用条件効果
クラスタリングキー1TB以上のテーブル・特定カラムでの頻繁なフィルタプルーニング率の向上
マテリアライズドビュー頻繁に実行される集約クエリ事前計算結果の再利用
検索最適化サービス高カーディナリティカラムの等値検索ポイントルックアップの高速化
ウェアハウスサイジング大規模クエリのスキャン量が多い場合並列処理能力の向上

学習戦略

Data Engineer試験はCore以上に実践的な知識が問われるため、ハンズオンを重視した学習が必要です。

  • Streams + Tasksのパイプラインを実際に構築し、SYSTEM$STREAM_HAS_DATAの動作を確認する
  • Dynamic Tablesを作成してTARGET_LAGの挙動を検証する
  • Snowpipeの自動取り込みをS3イベント通知で設定し、パイプステータスを確認する
  • VARIANT型にJSONデータを格納し、FLATTEN + LATERAL JOINで展開するクエリを書く
  • クエリプロファイルでスピリング・プルーニング率を確認する方法を覚える

データ保護のポイント

  • Time Travel:Enterprise Editionで最大90日間の過去データ参照。UNDROP TABLE / SELECT ... AT(TIMESTAMP =>)構文で復元・参照
  • Fail-safe:Time Travel期間終了後7日間のSnowflake側バックアップ。ユーザーからはアクセス不可
  • Zero-Copy Clone:CREATE TABLE ... CLONE構文でメタデータのみコピー。ストレージコストは変更差分のみ発生
  • データ暗号化:AES-256による透過的暗号化。ユーザー操作不要で常時有効

問題で確認

SnowPro Advanced: Data Engineer

問題 1

ソーステーブルに対するINSERT操作のみを追跡し、UPDATE/DELETEの変更は無視したい場合、どのStreamタイプを使用すべきですか?

  1. Standard Stream
  2. Append-only Stream
  3. Insert-only Stream
  4. Delta Stream

正解: B

Append-only StreamはINSERT操作のみを追跡し、UPDATEやDELETEの変更は記録しません。ログテーブルやイベントテーブルなど、追加専用のワークロードに最適です。Standard Streamは全DML操作を追跡します。Insert-only StreamはExternal Tables専用です。Delta Streamという種類は存在しません。

よくある質問

SnowPro Advanced Data Engineer試験にはCore認定が必須ですか?

はい、有効な(失効していない)SnowPro Core認定が受験の前提条件です。COF-C03に限らず、COF-C02で取得した認定も有効期限内であれば条件を満たします。Core認定が失効している場合は、先にCore試験に合格し直す必要があります。Core合格後すぐにAdvancedを受験することも可能ですが、Coreの知識を基盤としつつStreams/Tasks/Snowpipe/Dynamic Tablesなどの深い理解が求められるため、追加で4〜8週間の学習期間を確保することが推奨されます。

Dynamic TablesとStreams + Tasksの使い分けはどのように出題されますか?

試験ではシナリオベースで「宣言的にパイプラインを定義したい場合はDynamic Tables」「CDCベースで細かい制御が必要な場合はStreams + Tasks」という判断が問われます。Dynamic Tablesはターゲットテーブルの定義をSQLで宣言するだけで自動的にデータ更新される簡潔さが利点です。一方、Streams + Tasksは変更データの中間処理やエラーハンドリングを細かく制御できる柔軟性があります。

半構造化データの出題範囲はどの程度ですか?

半構造化データだけの独立したドメインはありません。英語版の公式Study Guide(DEA-C02、2026年3月6日更新)では、ドメイン1.0「Data Movement」(28%)の1.2に構造化・半構造化・非構造化データの取り込みとINFER_SCHEMAによるスキーマ検出が、ドメイン5.0「Data Transformation」(25%)の5.4に半構造化データと構造化データの相互変換が含まれます。VARIANT型へのJSON/XML格納、ドット記法・ブラケット記法によるアクセス、FLATTEN関数とLATERAL JOINによるネスト配列の展開、Parquet/ORC/Avroファイルのクエリ(SELECT $1 FROM @stage構文)を押さえておきましょう。

クラウドの基礎から読む

資格の話をしない、クラウドそのものの入門 8 章があります。登録なしで全部読めます。

第 0 部・無料

クラウド自体がはじめての方へ

サーバー・ネットワーク・データベースの前提知識なしで読める 8 章。登録不要・無料。

この記事で学んだ内容を問題で確認しましょう

16,000問以上の問題で実力チェック

無料で問題を解いてみる
この記事の著者

NicheeLab編集部

データエンジニアリング・クラウド資格の専門家。Databricks・Snowflake等の認定資格を保有し、実務経験に基づいた問題作成・解説を行っています。NicheeLab運営。


関連記事
Snowflake

Snowflake資格一覧|全11試験(SnowPro)の難易度・費用

Snowflake認定資格(SnowPro)全11試験の一覧・難易度・費用・出題範囲を徹底解説。SnowparkとDat...

Snowflake

Snowflake試験の難易度ランキング|全11資格を徹底比較

Snowflake(SnowPro)認定全11試験の難易度をランキング形式で比較。学習時間・合格に必要なスキルから分析。...

Snowflake

Snowflake資格の勉強方法|効率的な学習ルートと合格のコツ

Snowflake認定資格(SnowPro)に最短で合格するための勉強方法。公式リソース・学習スケジュールを徹底ガイド。...

Snowflake

SnowPro Core試験完全解説|出題範囲・問題例・合格戦略

SnowPro Core Certification(COF-C03)を徹底解説。出題範囲・100問の試験形式・合格ライ...

Snowflake

SnowPro Platform Associate(SOL-C01)完全解説|現在は予約不可・試験内容と次の受験先

SnowPro Associate: Platform(SOL-C01)は2026年10月時点でSnowflakeの公式...

Snowflakeの記事一覧 (102件)
© 2026 NicheeLab All rights reserved.