Azure Data Factory でファイルを移動する

適用対象: Azure Data Factory Azure Synapse Analytics

ADF コピー アクティビティには、ストレージとストア間でバイナリ ファイルをコピーするときの "移動" シナリオに対するサポートが組み込まれています。 これを有効にするには、コピー アクティビティで "deleteFilesAfterCompletion" を true に設定します。 そうすることで、ジョブの完了後に、コピー アクティビティによってデータ ソース ストアからファイルが削除されます。

この記事では、ADF の柔軟な制御フローとコピー アクティビティおよび削除アクティビティを利用して同じシナリオを実現するもう 1 つの方法として、ソリューション テンプレートについて説明します。 このテンプレートを使用する一般的なシナリオの 1 つ: ファイルは、ソース ストアのランディング フォルダーに継続的にドロップされます。 スケジュール トリガーを作成することにより、ADF パイプラインでこれらのファイルをソースから移動先ストアに定期的に移動できます。 ADF パイプラインで "ファイルの移動" を実現する方法では、ランディング フォルダーからファイルを取得し、各ファイルを移動先ストアの別のフォルダーにコピーした後、ソース ストアのランディング フォルダーから同じファイルを削除します。

このソリューション テンプレートについて

このテンプレートでは、ソースのファイル ベースのストアからファイルが取得されます。 次に、それぞれを移動先ストアに移動します。

このテンプレートには、5 つのアクティビティが含まれています。

• Getmetadata では、ソース ストアのフォルダーからファイルとサブフォルダーを含むオブジェクトのリストが取得されます。 オブジェクトは再帰的には取得されません。
• Filter では、GetMetadata アクティビティからのオブジェクト リストがフィルター処理されて、ファイルのみが選択されます。
• ForEach では、Filter アクティビティからファイル リストが取得されて反復処理され、各ファイルが Copy アクティビティと Delete アクティビティに渡されます。
• Copy では、ソース ストアからコピー先ストアに 1 つのファイルがコピーされます。
• Delete では、同じ 1 つのファイルがソース ストアから削除されます。

このテンプレートには、4 つのパラメーターが定義されています。

• SourceStore_Location は、ファイルの移動元となるソース ストアのフォルダー パスです。
• SourceStore_Directory は、ファイルの移動元となるソース ストアのサブフォルダー パスです。
• DestinationStore_Location は、ファイルの移動先となる移動先ストアのフォルダー パスです。
• DestinationStore_Directory は、ファイルの移動先となる移動先ストアのサブフォルダー パスです。

このソリューション テンプレートの使用方法

1. ファイルの移動テンプレートに移動します。 ファイル移動元のソース ファイル ストアに対する既存の接続を選択するか、新しい接続を作成します。 DataSource_Folder と DataSource_File では、ソース ファイル ストアの同じ接続が参照されていることに注意してください。

   

2. ファイル移動先の移動先ファイル ストアに対する既存の接続を選択するか、新しい接続を作成します。

   

3. [このテンプレートを使用] タブを選択します。

4. 次の例に示すように、パイプラインが表示されます。

   

5. [デバッグ] を選択し、 [パラメーター] で入力し、 [完了] を選択します。 パラメーターは、ファイル移動元のフォルダー パスと、ファイル移動先のフォルダー パスです。

   

6. 結果を確認します。

   

関連するコンテンツ

• Azure Data Factory で LastModifiedDate に基づいて新規および変更済みのファイルをコピーする

• Azure Data Factory を使用して複数のコンテナーからファイルをコピーする