レイクハウスのデータ インジェスト オプション

簡単なファイルアップロードからスケーラブルなパイプライン、リアルタイムストリーミングまで、レイクハウスにデータを取り込むにはいくつかの方法があります。 適切なアプローチは、データ ソース、ボリューム、変換の複雑さ、および 1 回限りの読み込みまたは継続的インジェストが必要かどうかによって異なります。

レイクハウスにデータを読み込む方法

以下のセクションでは、各アプローチ—ファイルアップロード、ショートカット、データフローGen2、データパイプライン、ノートブックコード、イベントストリーム—を、最も単純なノーコードオプションからより高度なプログラム的・リアルタイム手法まで順に説明します。

ファイルをアップロードする

変換を行わずに小さなファイルをレイクハウスに読み込むには、Lakehouse エクスプローラーを使用してローカル コンピューターから直接アップロードします。

簡略化された手順

ショートカットを使用すると、他のストレージの場所にあるデータをコピーせずに参照できます。 ショートカットはレイクハウス内のフォルダーとして表示されますが、別の lakehouse、Azure Data Lake Storage Gen2 アカウント、Amazon S3、またはその他のサポートされているソースに格納されているデータを指します。 ショートカットは、データを複製せずにソース間でクエリを実行または結合する場合に便利です。 詳細については、「レイクハウスのショートカット」を参照してください。

データフロー Gen2

Dataflow Gen2 は、200 を超えるコネクタを備えたローコードのデータ変換ツールです。 Power Query インターフェイスで変換を視覚的に定義し、結果を lakehouse テーブルに出力します。 Dataflow Gen2 は、小さなデータセットや、他のツールで使用できないコネクタが必要な場合に適しています。 詳細については、「最初の データフローを作成してデータを取得および変換する」を参照してください。

データ パイプライン

データ パイプラインは、大量のデータを Lakehouse に移動するためのスケーラブルなコピー ツールを提供します。 コピー アクティビティは、さまざまなデータ ソースに接続し、元の形式でデータを読み込んだり、Delta テーブルに変換したりできます。 パイプラインのスケジュール設定、イベントに基づくトリガー、複数のアクティビティの連結を行うことができます。 詳細については、「コピー クティビティを使用してデータをコピーする方法」を参照してください。

ノートブック コード

Spark ノートブックを使用すると、データ インジェストをプログラムで完全に制御できます。 Spark ライブラリを使用してデータ ソースに接続し、データを DataFrame に読み込み、変換を適用して、結果を Lakehouse に保存します。 このアプローチは最も柔軟性が高く、他のツールでサポートされていない複雑な変換ロジックやソースに適しています。

Eventstream

Eventstream は、さまざまなソースから大量のリアルタイム イベントを取り込み、処理し、ルーティングします。 Lakehouse を宛先として追加して、ストリーミング データを Delta テーブルに直接配置できます。

詳細については、「 Get data from eventstream in a lakehouse」をご覧ください。

時系列や高スループットのストリーミングシナリオでは、イベントハウスにイベントをストリーミングし、OneLakeの利用可能性を有効にすることもできます。 これにより、OneLake に Delta テーブルが作成され、レイクハウスはショートカットを介してアクセスできます。 詳細については、 イベントハウスのOneLakeの空き状況をご覧ください。

アプローチを選択する

次の表は、各方法を使用してレイクハウスにデータを読み込む場合の概要を示しています。

関連するコンテンツ

• レイクハウスのショートカット
• Spark を使用したレイクハウスへのデータ ストリーミング
• コピー アクティビティを使用してデータをコピーする方法
• 初めてのデータフローを作成してデータの取得と変換を行う
• ノートブックを使用してレイクハウス内のデータを探索する
• イベントストリームにレイクハウスの宛先を追加する
• Eventhouse OneLake の可用性