Microsoft Fabric で Dataflow Gen2 のパラメーターを Pipeline から動的に渡して実行する方法

Posted at 2026-03-26

背景

Dataflow Gen2 ではパラメーターを利用することで、データフロー本体を都度作り替えなくても、入力値や処理対象を柔軟に切り替えられます。
そのため、用途ごとに似たようなデータフローを複数作成するのではなく、1 つのパラメーター化された Dataflow Gen2 を再利用しながら運用しやすくなります。

また、Fabric Pipeline から複数の Dataflow Gen2 をオーケストレーションし、Pipeline 側で定義したパラメーターを各データフローへ受け渡すことで、処理内容を動的に切り替えることもできます。

本記事では、こうしたシナリオをハンズオン形式で確認します。
あわせて、データソースが SQL Server の場合に、Dataflow Gen2 からカスタム SQL を利用しつつ、パラメーターをどのように扱えるかも確認します。

参考記事

https://learn.microsoft.com/ja-jp/fabric/data-factory/dataflow-parameters
https://learn.microsoft.com/ja-jp/fabric/data-factory/dataflow-gen2-parameterized-dataflow
https://learn.microsoft.com/en-us/powerquery-m/value-nativequery

なお、今回のシナリオでは SQL Server をデータソースとして利用するため、Dataflow Gen2 からカスタム SQL を実行する際に Value.NativeQuery を使用します。

参考

手順

1. 新規 Dataflow Gen2 を作成する

2. データフロー名を指定する

3. パブリックパラメーターモードを有効にする

参考： https://learn.microsoft.com/ja-jp/fabric/data-factory/dataflow-parameters

Dataflow Gen2 で定義したパラメーターを Pipeline から参照・上書きできるようにするため、パブリックパラメーターモードを有効にします。

4. パラメーターを定義する

今回はサンプルとして、以下の 2 つのパラメーターを定義します。

df_paramDB1 = SalesStarDW
- 接続先のデータベース名
df_paramTable1 = DimProduct
- 接続先のテーブル名

5. データを取得する

データを取得するボタンを選択します。

6. 空のクエリを選択する

今回は Power Query で直接クエリを記述するため、空のクエリを選択します。

7. 事前に定義したパラメーターをクエリで利用する

事前に定義した df_paramDB1 と df_paramTable1 を使って、以下のようにクエリを記述します。

let
    Source = Sql.Database("DB接続情報.xxx.azure.com", df_paramDB1),
    Result =
        Value.NativeQuery(
            Source,
            "SELECT * FROM dbo."& df_paramTable1 &""
        )
in
    Result

このクエリでは、接続先のデータベース名とテーブル名をパラメーターとして指定しています。
そのため、Dataflow Gen2 側で定義した値を変更することで、取得対象を切り替えられるかを確認できます。

今回は検証用のシナリオとして、Dataflow Gen2 で受け取ったパラメーターがクエリに反映されることを確認します。