適用対象:
Azure Data Factory Azure Synapse Analytics
ヒント
企業向けのオールインワン分析ソリューションである Microsoft Fabric の Data Factory をお試しください。 Microsoft Fabric では、データ移動からデータ サイエンス、リアルタイム分析、ビジネス インテリジェンス、レポートまで、あらゆるものが対象です。 新しい試用版を無料で開始する方法について説明します。
この記事では、Azure Data Factory と Azure Synapse でサポートされているシステム変数について説明します。 これらの変数は、いずれかのサービス内でエンティティを定義するときに式で使用できます。
パイプラインのスコープ
これらのシステム変数は、パイプライン JSON 内の任意の場所で参照できます。
| 変数名 | 説明 |
|---|---|
| @pipeline().DataFactory | パイプライン実行が実行されているデータまたは Synapse ワークスペースの名前 |
| @pipeline().Pipeline | パイプラインの名前 |
| @pipeline().RunId | 特定のパイプライン実行の ID |
| @pipeline().TriggerType | パイプラインを呼び出したトリガーの種類 (例: ScheduleTrigger、BlobEventsTrigger)。 サポートされているトリガーの種類の一覧については、「 パイプラインの実行とトリガー」を参照してください。
Manual のトリガーの種類は、パイプラインが手動でトリガーされたことを示します。 |
| @pipeline().TriggerId | パイプラインを呼び出したトリガーの ID |
| @pipeline().TriggerName | パイプラインを呼び出したトリガーの名前 |
| @pipeline().TriggerTime | パイプラインを呼び出したトリガーの実行時刻。 これは、トリガーが 実際に 発生してパイプラインの実行を呼び出す時刻であり、トリガーのスケジュールされた時刻とは若干異なる場合があります。 |
| @pipeline().GroupId | パイプラインの実行が属するグループの ID。 |
| @pipeline()?.パイプライン名によってトリガーされました | パイプラインの実行をトリガーするパイプラインの名前。 ExecutePipeline アクティビティによってパイプラインの実行がトリガーされる場合に関係します。 他の状況で使用する場合は Null に評価されます。 @pipeline() の後の疑問符に注意してください |
| @pipeline()?.TriggeredByPipelineRunId (トリガーバイパイプラインランイド) | パイプラインの実行をトリガーするパイプラインの実行 ID。 ExecutePipeline アクティビティによってパイプラインの実行がトリガーされる場合に関係します。 他の状況で使用する場合は Null に評価されます。 @pipeline() の後の疑問符に注意してください |
注
トリガー関連の日付/時刻のシステム変数 (パイプラインとトリガーの両方のスコープ) は、ISO 8601 形式で UTC 日付を返します (例: 2017-06-01T22:20:00.4061448Z)。
スケジュール トリガーのスコープ
これらのシステム変数は、 ScheduleTrigger 型のトリガーのトリガー JSON 内の任意の場所で参照できます。
| 変数名 | 説明 |
|---|---|
| @trigger().scheduledTime | トリガーがパイプライン実行を呼び出すようにスケジュールされた時間。 |
| @trigger().startTime | パイプラインの実行を呼び出すために トリガーが実際に 起動された時刻。 これは、トリガーのスケジュールされた時刻とはやや異なる場合があります。 |
タンブリング ウィンドウ トリガーのスコープ
これらのシステム変数は、 TumblingWindowTrigger 型のトリガーに対してトリガー JSON 内の任意の場所で参照できます。
| 変数名 | 説明 |
|---|---|
| @trigger().outputs.windowStartTime | トリガーの実行に関連付けられているウィンドウの開始。 |
| @trigger().outputs.windowEndTime | トリガーの実行に関連付けられているウィンドウの終了。 |
| @trigger().scheduledTime | トリガーがパイプライン実行を呼び出すようにスケジュールされた時間。 |
| @trigger().startTime | パイプラインの実行を呼び出すために トリガーが実際に 起動された時刻。 これは、トリガーのスケジュールされた時刻とはやや異なる場合があります。 |
ストレージ イベント トリガーのスコープ
これらのシステム変数は、 BlobEventsTrigger 型のトリガーに対してトリガー JSON 内の任意の場所で参照できます。
| 変数名 | 説明 |
|---|---|
| @triggerBody().fileName | 作成または削除によってトリガーが起動されたファイルの名前。 |
| @triggerBody().folderPath |
@triggerBody().fileName で指定されたファイルを含むフォルダーへのパス。 フォルダー パスの最初のセグメントは、Azure Blob Storage コンテナーの名前です。 |
| @trigger().startTime | パイプライン実行を呼び出すためにトリガーが起動した時刻。 |
注
Azure Synapse Analytics でパイプラインとトリガーを作成する場合は、パラメーターとして@trigger().outputs.body.fileNameと@trigger().outputs.body.folderPathを使用する必要があります。 これら 2 つのプロパティによって、BLOB 情報がキャプチャされます。
@triggerBody().fileName と @triggerBody().folderPath の代わりに、これらのプロパティを使用してください。
カスタム イベント トリガーのスコープ
これらのシステム変数は、 CustomEventsTrigger 型のトリガーのトリガー JSON 内の任意の場所で参照できます。
注
このサービスでは、カスタム イベントが Azure Event Grid イベント スキーマで書式設定されることを想定しています。
| 変数名 | 説明 |
|---|---|
| @triggerBody().event.eventType | カスタム イベント トリガーの実行をトリガーしたイベントの種類。 イベントの種類は、顧客が定義したフィールドで、文字列型の任意の値を取ります。 |
| @triggerBody().event.subject | トリガーを起動するカスタム イベントの件名。 |
| @triggerBody().event.data._keyName_ | カスタム イベントのデータ フィールドは、JSON BLOB から無料で利用でき、顧客がメッセージとデータを送信するために使用できます。 各フィールドを参照するには、データのkeyNameを使用してください。 たとえば、@triggerBody().event.data.callbackは、データの下に格納されているコールバック フィールドの値を返します。 |
| @trigger().startTime | パイプライン実行を呼び出すためにトリガーが起動した時刻。 |
注
Azure Synapse Analytics でパイプラインとトリガーを作成する場合は、パラメーターとして@trigger().outputs.body.eventを使用する必要があります。 このプロパティはイベントの情報をキャプチャします。
@triggerBody().event を使う代わりに、このプロパティを使います。
関連するコンテンツ
- これらの変数を式で使用する方法については、「 式の言語と関数」を参照してください。
- パイプラインでトリガー スコープのシステム変数を使用するには、パイプラインのトリガー メタデータの参照に関する説明を参照してください。