Instiq
第3章 · データパイプラインのオーケストレーション·v1.0.0·更新 2026/6/15·読了目安 約14分

変更要約: Associate Data Practitioner 第3章を新規作成(ドメイン3「パイプライン」: パイプラインの設計=Dataproc/Dataflow/Cloud Data Fusion/Cloud Composer/Dataform/ELT・ETL、スケジュール・自動化・監視=スケジュールクエリ/Cloud Scheduler/Workflows/Dataproc Workflow Templates/Pub/Sub→BigQuery/Eventarc/Dataflow ジョブ UI/Cloud Logging・Monitoring)。

3.1データパイプラインの設計

この節の要点

ビジネス要件に応じたデータ変換ツール(Dataproc・Dataflow・Cloud Data Fusion・Cloud Composer・Dataform)の選択、ELT と ETL のユースケースの評価、そして基本的な変換パイプラインを実装するために必要なプロダクトの組み合わせを理解します。

データを定期的・自動的に流して変換する仕組みが データパイプライン です。要件(既存資産・スキル・規模・リアルタイム性)に応じて、適したツールを選びます。

3.1.1変換ツールの選択

ツール向いている用途
Dataflowバッチ/ストリーミングのスケーラブルな処理(Apache Beam)
Dataproc既存の Spark/Hadoop ジョブ
Cloud Data Fusionビジュアルに ETL/ELT を構築(コード少なめ)
DataformBigQuery 内の SQL ベースの変換(ELT)
Cloud Composer複数ステップのオーケストレーション(Airflow)

Dataflow は Apache Beam ベースでバッチ/ストリーミングをスケーラブルに処理します。既存の Spark/Hadoop 資産があれば Dataprocビジュアルに低コードで組むなら Cloud Data Fusion、BigQuery 内で SQL ベースの変換(ELT) を管理するなら Dataform が向きます。複数ステップの依存関係をオーケストレーションするのが Cloud Composer(Airflow ベース)です。「Spark/Hadoop=Dataproc」「SQL の ELT 管理=Dataform」「ワークフローの統制=Cloud Composer」と結びます。

試験ポイント

要件 → ツール」が頻出。例:「スケーラブルなバッチ/ストリーミング」=Dataflow、「既存 Spark/Hadoop を移す」=Dataproc、「ビジュアルに低コードで ETL」=Cloud Data Fusion、「BigQuery 内の SQL 変換(ELT)を管理」=Dataform、「複数ステップの依存をオーケストレーション」=Cloud Composer。

注意

混同に注意:
Dataflow(Beam・スケーラブル処理)Dataproc(Spark/Hadoop)の違い。
Cloud Composer(Airflow・オーケストレーション)は変換そのものよりワークフロー統制
Dataform は BigQuery の SQL ELT 管理。

Dataflow(Beam・スケーラブル)/Dataproc(Spark・Hadoop)/Cloud Data Fusion(ビジュアル)/Dataform(SQL ELT)/Cloud Composer(オーケストレーション)の使い分けを示す図。
変換ツールの選択

3.1.2この節のまとめ

  • Dataflow(Beam・バッチ/ストリーミング)/Dataproc(Spark/Hadoop)/Cloud Data Fusion(ビジュアル)/Dataform(SQL ELT)
  • Cloud Composer(Airflow)で複数ステップをオーケストレーション
  • 要件(既存資産・スキル・規模)でツールを選ぶ

進捗の記録にはログインが必要です。

理解度チェック

(軽い確認用)

Q1. 既存の Spark / Hadoop のジョブをそのまま Google Cloud で動かしたい。最適なのはどれですか?

Q2. スケーラブルにバッチとストリーミングのデータ変換を行いたい(Apache Beam ベース)。最適なのはどれですか?

Q3. BigQuery 内の SQL ベースの変換(ELT)をバージョン管理しながら実装したい。最適なのはどれですか?

Q4. 複数ステップの依存関係を持つデータワークフローをオーケストレーションしたい。最適なのはどれですか?

Q5. コードをあまり書かず、ビジュアルに ETL/ELT パイプラインを構築したい。最適なのはどれですか?

Q6. Cloud Composer の主な役割として最も適切なものはどれですか?

理解度を確認第3章「データパイプラインのオーケストレーション」の問題を解く