Azure Data FactoryとAzure Synapse Analyticsで変数アクティビティを設定する

適用対象: Azure Data Factory Azure Synapse Analytics

ヒント

Data Factory in Microsoft Fabric は、よりシンプルなアーキテクチャ、組み込みの AI、および新機能を備えた次世代のAzure Data Factoryです。 データ統合を初めて使用する場合は、Fabric Data Factory から始めます。 既存の ADF ワークロードをFabricにアップグレードして、データ サイエンス、リアルタイム分析、レポートの新機能にアクセスできます。

ヒント

Microsoft Fabricのデータファクトリーにおける同等の活動については、「Set Variable activity」を参照してください。

変数の設定アクティビティを使用して、Data Factory または Synapse パイプラインに定義された文字列型、ブール型、または配列型の既存の変数の値を設定、または変数の設定アクティビティを使用してパイプラインの戻り値 (プレビュー) を設定します。

UI を使用して変数の設定アクティビティを作成する

パイプライン内で変数の設定アクティビティを使用するには、次の手順を実行します。

  1. パイプライン キャンバスの背景を選び、[変数] タブを使用して変数を追加します。

[変数] タブが選択され、TestVariable という配列型変数がある空のパイプライン キャンバスのスクリーンショット。

  1. パイプラインのアクティビティ ペイン内で "変数の設定" を検索し、変数の設定アクティビティをパイプライン キャンバスにドラッグします。

  2. まだ選択していない場合は、キャンバス上で変数の設定アクティビティを選択し、[設定] タブを選択して、その詳細を編集します。

  3. [変数の種類] として [パイプライン変数] を選択します。

  4. [名前] プロパティの変数を選びます。

  5. 変数の値を設定する式を入力します。 この式には、リテラル文字列式、または動的な式、関数、システム変数、または他のアクティビティからの出力の任意の組み合わせを使用できます。

変数の設定アクティビティの UI のスクリーンショット。

UI を使用したパイプラインの戻り値の設定

[変数を設定] アクティビティを展開して、パイプラインの戻り値 という名前の特別なシステム変数を含めます。次のシナリオでは、子パイプラインから呼び出し元パイプラインへの通信が可能になります。

使用する前に、変数を定義する必要はありません。 詳細については、パイプラインの戻り値に関するページを参照してください。

ExecutePipeline アクティビティのスクリーンショット。

型のプロパティ

プロパティ 説明 必須
name パイプラインのアクティビティの名前 はい
説明 アクティビティの動作を説明するテキスト no
型 SetVariable に設定する必要があります はい
variableName このアクティビティによって設定される変数の名前 はい
value 変数が割り当てられる文字列リテラルまたは式オブジェクトの値 はい

変数のインクリメント

変数に関するよくあるシナリオの 1 つに、Until または ForEach アクティビティ内で変数を反復子として使用するというものがあります。 [変数を設定] アクティビティでは、value フィールドに設定されている変数を参照することはできません。つまり、自己参照はサポートされていません。 この制限を回避するには、一時変数を設定してから、2 番目の [変数の設定] アクティビティを作成します。 2 番目の [変数の設定] アクティビティでは、反復子の値が一時変数に設定されます。 このパターンの例を次に示します。

  • まず、イテレーター用と一時ストレージ用の 2 つの変数を定義します。

スクリーンショットは変数の定義を示しています。

  • 次に、2 つのアクティビティを使用して値をインクリメントします

増分変数を示すスクリーンショット。 

{
    "name": "pipeline1",
    "properties": {
        "activities": [
            {
                "name": "Increment J",
                "type": "SetVariable",
                "dependsOn": [],
                "policy": {
                    "secureOutput": false,
                    "secureInput": false
                },
                "userProperties": [],
                "typeProperties": {
                    "variableName": "temp_j",
                    "value": {
                        "value": "@add(variables('counter_i'),1)",
                        "type": "Expression"
                    }
                }
            },
            {
                "name": "Set I",
                "type": "SetVariable",
                "dependsOn": [
                    {
                        "activity": "Increment J",
                        "dependencyConditions": [
                            "Succeeded"
                        ]
                    }
                ],
                "policy": {
                    "secureOutput": false,
                    "secureInput": false
                },
                "userProperties": [],
                "typeProperties": {
                    "variableName": "counter_i",
                    "value": {
                        "value": "@variables('temp_j')",
                        "type": "Expression"
                    }
                }
            }
        ],
        "variables": {
            "counter_i": {
                "type": "Integer",
                "defaultValue": 0
            },
            "temp_j": {
                "type": "Integer",
                "defaultValue": 0
            }
        },
        "annotations": []
    }
}

変数は、パイプライン レベルでスコープされます。 つまり、これらはスレッド セーフではなく、ForEach ループなどの並列反復アクティビティ内からアクセスされた場合 (特に、その ForEach アクティビティ内で値も変更される場合)、予想外の望ましくない動作を引き起こす可能性があります。

関連コンテンツ

制御フローに関連するその他のアクティビティを確認します。

  • Last updated on