このモジュールは約 10 分で完了できます。 このチュートリアルの最後の部分では、パイプライン内のすべてのジョブが完了したときに通知する電子メールを送信し、スケジュールに従って実行するようにパイプラインを構成する方法について説明します。
[前提条件]
このチュートリアル シリーズのモジュール 1: Data Factory を使用してパイプラインを作成する
Office 365 Outlook アクティビティをパイプラインに追加する
パイプライン エディターで [ アクティビティ ] タブを選択し、Office Outlook アクティビティを見つけます。
新しい Office Outlook アクティビティを選択し、[ 設定] タブを選択します。
まだサインインしていない場合は Office アカウントにサインインし、メッセージが表示されたら、メール アドレスを使用する同意を付与します。
注
このサービスは現在、個人の電子メールをサポートしていません。 エンタープライズ メール アドレスを使用する必要があります。
コピー アクティビティから新しい Office 365 Outlook アクティビティに、 成功 時パス (パイプライン キャンバスのアクティビティの右上にある緑色のチェック ボックス) を選択してドラッグします。
パイプライン キャンバスから Office 365 Outlook アクティビティを選択し、キャンバスの下にあるプロパティ領域の [設定] タブを選択してメールを構成します。
- [ 宛先 ] セクションにメール アドレスを入力します。 複数のアドレスを使用する場合は、 ; を使用してアドレスを区切ります。
- [件名] で、フィールドを選択して [動的コンテンツの追加] オプションが表示されるようにし、それを選択してパイプライン式ビルダー キャンバスを表示します。
[パイプライン式ビルダー] ダイアログが表示されます。 次の式を入力し、[ OK] を選択します。
@concat('1時間での DI パイプラインが成功しました。パイプライン実行 ID:', pipeline().RunId)
[本文] で、もう一度フィールドを選択し、テキスト領域の下に表示されたら [動的コンテンツの追加] オプションを選択します。 表示される パイプライン式ビルダー ダイアログで、次の式を (独自のコピー アクティビティ名で) 再度追加し、[ OK] を選択します。
@concat('RunID = ', pipeline().RunId, ' ;', 'コピーされた行数 ', activity('Copy data1').output.rowsCopied, ' ;','スループット ', activity('Copy data1').output.throughput)
Von Bedeutung
Copy data1 を独自のパイプライン コピー アクティビティの名前に置き換えます。
最後に、パイプライン エディターの上部にある [ ホーム ] タブを選択し、[ 実行] を選択します。 次に、[ 保存] を選択し、 確認ダイアログでもう一度実行して、これらのアクティビティを実行します。
パイプラインが正常に実行されたら、電子メールを確認して、パイプラインから送信された確認メールを見つけます。
パイプラインの実行をスケジュールする
パイプラインの開発とテストが完了したら、自動的に実行されるようにスケジュールできます。
パイプライン エディター ウィンドウの [ホーム] タブで、[スケジュール] を選択します。
必要に応じてスケジュールを構成します。 この例では、年の終わりまで毎日午後 8 時に実行するようにパイプラインをスケジュールします。
(省略可能) パイプラインにデータフロー アクティビティを追加する
「モジュール 2: Data Factory でデータフローを作成する」で作成したデータフローをパイプラインに追加することもできます。
パイプライン キャンバスのコピー アクティビティと Office 365 Outlook アクティビティを接続する緑色の線にカーソルを合わせ、 + ボタンを選択して新しいアクティビティを挿入します。
表示されるメニューから [データフロー ] を選択します。
新しく作成されたデータフロー アクティビティは、コピー アクティビティと Office 365 Outlook アクティビティの間に挿入され、キャンバスの下の領域にそのプロパティが表示され、自動的に選択されます。 プロパティ領域の [設定] タブを選択し、「 モジュール 2: Data Factory でデータフローを作成する」で作成したデータフローを選択します。
関連コンテンツ
Microsoft Fabric の Data Factory を使用した最初のデータ統合パイプラインのエンド ツー エンドチュートリアルでは、次の方法について学習しました。
- コピー アクティビティを使用して、ソース ストアから Data Lakehouse 内のテーブルに生データを取り込みます。
- データフロー アクティビティを使用してデータを処理し、Lakehouse の新しいテーブルに移動します。
- Office 365 Outlook アクティビティを使用して、すべてのジョブが完了したら通知する電子メールを送信します。
- スケジュールに基づいて実行するようにパイプラインを構成します。
- (省略可能) 既存のパイプライン フローにデータフロー アクティビティを挿入します。
チュートリアルを完了したので、独自のパイプラインとフローを構築する準備ができました。 パイプラインの実行を監視する方法の詳細も確認できます。