【でーたぱいぷらいん】

データパイプライン とは?

最終更新:
💡 データの「水道管」を設計して、必要な場所に届ける

データを入力元から目的地へ運び、必要な加工や検証などを行う一連の処理フロー。定期実行や継続的な処理を自動化し、分析などにつなげる。

📌 このページのポイント
売上データを分析へつなぐ例 入力 売上データ 変換 日付を統一 保存 分析用DB 活用 集計・分析 バッチ:範囲をまとめて処理 ストリーム:到着データを継続処理 監視・検証・再実行も設計する
取得→変換→格納のETLを含む例。格納後に変換するELTなど、処理順や構成は目的によって変わる。
ひよこ ひよこ
データパイプラインって何をつなぐの?
ペンギン先生 ペンギン先生
たとえば売上データを取得し、日付の形式をそろえて、分析用のデータベースに保存する処理をつなぐんだ。元データから目的地までの移動や加工を、一連の流れとして扱うよ。
ひよこ ひよこ
ETLとは違うの?
ペンギン先生 ペンギン先生
ETLは取得・変換・格納の順で進めるパイプラインの一例だよ。先に格納してから変換するELTや、変換せずに転送する流れもあるんだ。
ひよこ ひよこ
バッチとストリーミングはどう違うの?
ペンギン先生 ペンギン先生
バッチは一定範囲のデータをまとめて処理し、ストリーミングは到着するデータを継続的に処理するよ。後者でも遅延はあるので、必要な鮮度や処理量に合わせて選ぶんだ。
ひよこ ひよこ
自動で動かせば、必ず最後まで届く?
ペンギン先生 ペンギン先生
通信や処理の失敗もあるから、検証や監視、失敗した処理の再実行を設計する必要があるよ。自動化そのものが成功を保証するわけではないんだ。
ひよこ ひよこ
どんなツールが役立つの?
ペンギン先生 ペンギン先生
たとえばApache Airflowはバッチのワークフローをコードで定義し、実行順序やスケジュール、状態を管理するよ。実際の変換や保存には、目的に合う処理系やデータベースを組み合わせるんだ。
ペンギン
まとめ:ざっくりこれだけ覚えればOK!
「データパイプライン」って出てきたら「データを目的地へ運び、必要な処理をつなぐ流れ」と思えばだいたいOK!
📖 おまけ:英語の意味
「Data Pipeline」 = データの導管
💬 Pipeline(パイプライン=送管)のように、データを源泉から目的地まで自動で流す仕組みだよ

参考資料

← 用語集にもどる