アクティビティは、Microsoft Fabric でエンドツーエンドのデータ ワークフローを作成するのに役立つ構成要素です。 ビジネス ニーズに合わせてデータを移動および変換するタスクと考えてください。 コピー アクティビティを使用して、SQL Server から Azure Blob Storage にデータを移動できます。 その後、データフロー アクティビティまたは Notebook アクティビティを追加して、そのデータを処理して変換してから、レポート用に Azure Synapse Analytics に読み込むことができます。
アクティビティは、特定の目標を達成するためにパイプラインにグループ化されます。 たとえば、次のパイプラインを作成できます。
- さまざまなソースからログ データをプルする
- そのデータをクリーンアップして整理する
- 分析を実行して分析情報を検索する
アクティビティをパイプラインにグループ化すると、各アクティビティを個別に処理するのではなく、これらすべての手順を 1 つの単位として管理できます。 パイプライン全体を一度にデプロイしてスケジュールし、必要なときにいつでも実行できます。
Microsoft Fabric には、次の 3 種類のアクティビティが用意されています。
- データ移動アクティビティ - システム間でデータを移動する
- データ変換アクティビティ - データの処理と変換
- フロー アクティビティの制御 - パイプラインの実行方法を管理する
データ移動アクティビティ
これらのアクティビティは、パイプライン内のある場所から別の場所にデータを移動するのに役立ちます。
| 移動アクティビティ | Description |
|---|---|
| データのコピー | サポートされている任意のソースから、サポートされている任意のコピー先にデータをコピーできます。 使用可能な機能については、 コネクタの概要 を参照してください。 |
| コピー作業 | コピー ジョブは、データをすばやく移動するための簡略化された方法です。 |
さまざまなデータ移動オプションを選択する必要がある場合は、 データ移動の決定ガイド の記事を参照してください。
データ変換アクティビティ
これらのアクティビティは、データの処理と変換に役立ちます。 個別に使用することも、他のアクティビティと一緒に連結することもできます。
詳細については、データ変換アクティビティに関する記事を参照してください。
| データ変換アクティビティ | コンピューティング環境 |
|---|---|
| データのコピー | Microsoft Fabric によるコンピューティング マネージャー |
| Dataflow Gen2 | Microsoft Fabric によるコンピューティング マネージャー |
| データの削除 | Microsoft Fabric によるコンピューティング マネージャー |
| ファブリックノートブック (Fabric Notebook) | Microsoft Fabric によって管理される Apache Spark クラスター |
| HDInsight アクティビティ | Microsoft Fabric によって管理される Apache Spark クラスター |
| Spark ジョブ定義 | Microsoft Fabric によって管理される Apache Spark クラスター |
| ストアド プロシージャ | Azure SQL、Azure Synapse Analytics、または SQL Server |
| SQL スクリプト | Azure SQL、Azure Synapse Analytics、または SQL Server |
制御フロー アクティビティ
これらのアクティビティは、パイプラインの実行方法を制御するのに役立ちます。
| 制御活動 | Description |
|---|---|
| 変数の追加 | 既存の配列変数に値を追加します。 |
| Azure Batch アクティビティ | Azure Batch スクリプトを実行します。 |
| Azure Databricks アクティビティ | Azure Databricks ジョブ (Notebook、Jar、Python) を実行します。 |
| Azure Machine Learning アクティビティ | Azure Machine Learning ジョブを実行します。 |
| アクティビティを無効化 | 別のアクティビティを非アクティブ化します。 |
| Fail | カスタマイズされたエラー メッセージとエラー コードが表示されてパイプラインの実行が失敗します。 |
| Filter | 入力配列にフィルター式を適用する |
| ForEach | ForEach アクティビティは、パイプライン内の繰り返し制御フローを定義します。 このアクティビティは、コレクションを反復処理するために使用され、指定されたアクティビティをループで実行します。 このアクティビティのループの実装は、プログラミング言語の Foreach ループ構造に似ています。 |
| 機能アクティビティ | Azure 関数を実行します。 |
| メタデータを取得する | GetMetadata アクティビティを使用すると、Data Factory または Synapse のパイプラインで任意のデータのメタデータを取得できます。 |
| If 条件 | If Condition は、true または false として評価される条件に基づき分岐を行うために使用できます。 If Condition アクティビティは、プログラミング言語における if ステートメントと同じ働きを持ちます。 条件が true に評価されたときの一連のアクティビティと false に評価されたときの一連のアクティビティが評価されます。 |
| パイプラインの呼び出し | Execute Pipeline アクティビティを使用すると、Data Factory または Synapse の 1 つのパイプラインから別のパイプラインを呼び出すことができます。 |
| KQL アクティビティ | Kusto インスタンスに対して KQL スクリプトを実行します。 |
| ルックアップ アクティビティ | ルックアップ アクティビティを使用して、任意の外部ソースからレコード/テーブル名/値を読み取ったり検索したりできます。 この出力は、後続のアクティビティによってさらに参照できます。 |
| 変数の設定 | 既存の変数の値を設定します。 |
| アクティビティの切り替え | switch 式を実装します。これにより、この式がもたらす可能性のある結果ごとに、複数の後続のアクティビティが可能になります。 |
| Teams アクティビティ | Teams チャネルまたはグループ チャットにメッセージを投稿します。 |
| アクティビティまで | プログラミング言語の Do-Until ループ構造に似た Do-Until ループを実装します。 Until アクティビティでは、そこに関連付けられている条件が true に評価されるまで、一連のアクティビティがループ実行されます。 Until アクティビティにはタイムアウト値を指定できます。 |
| 待機アクティビティ | パイプラインで Wait アクティビティを使用すると、パイプラインは、指定した期間待った後、後続のアクティビティの実行を続行します。 |
| Web アクティビティ | Web アクティビティを使用すると、パイプラインからカスタム REST エンドポイントを呼び出すことができます。 |
| Webhook アクティビティ | Webhook アクティビティを使用すると、エンドポイントを呼び出し、コールバック URL を渡すことができます。 パイプラインの実行は、コールバックが呼び出されるのを待ってから、次のアクティビティに進みます。 |
Microsoft Fabric UI を使用したパイプラインへのアクティビティの追加
パイプラインにアクティビティを追加して構成する方法を次に示します。
- ワークスペースに新しいパイプラインを作成します。
- [アクティビティ] タブに移動し、使用可能なアクティビティを参照します。 右にスクロールしてすべてのオプションを表示し、アクティビティを選択してパイプライン エディターに追加します。
- アクティビティを追加してキャンバス上で選択すると、下のプロパティ ウィンドウに [ 全般 ] 設定が表示されます。
- 各アクティビティには、プロパティ ウィンドウの他のタブに他の構成オプションがあります。
![[アクティビティ] タブ、ツール バー、Copy アクティビティ、[全般] タブとそのプロパティ、全て強調表示されているパイプライン エディターのスクリーンショット。](media/activity-overview/activity-ui.png)
全般設定
パイプラインに新しいアクティビティを追加して選択すると、画面の下部にそのプロパティが表示されます。 これには、[全般]、[設定]、および場合によっては他のタブが含まれます。
![アクティビティの [全般] 設定タブを示すスクリーンショット。](media/activity-overview/general-settings.png)
すべてのアクティビティには、全般設定の [名前] フィールドと [ 説明 ] フィールドが含まれます。 一部のアクティビティには、次のオプションもあります。
| Setting | Description |
|---|---|
| Timeout | タイムアウトするまでのアクティビティの実行時間。既定値は 12 時間で、最大値は 7 日間です。 D.HH:MM:SS の形式を使用します。 |
| Retry | アクティビティが失敗した場合に再試行する回数。 |
| (詳細プロパティ) 再試行間隔 (秒) | 再試行の間に待機する秒数。 |
| (詳細プロパティ) セキュリティで保護された出力 | 選択すると、アクティビティの出力はログに表示されません。 |
| (詳細プロパティ) セキュリティで保護された入力 | 選択すると、アクティビティの入力はログに表示されません。 |
Note
既定では、パイプラインあたり最大 120 個のアクティビティを使用できます。 これには、コンテナーの内部アクティビティが含まれます。