レコードセット変換先を使用する

  • [アーティクル]

適用対象: SQL Server Azure Data Factory の SSIS Integration Runtime

レコードセット変換先では、データは外部データ ソースに保存されません。 代わりに、レコードセット変換先では、Object データ型の Integration Services パッケージ変数に格納されるレコードセットのメモリにデータが保存されます。 レコードセット変換先でデータが保存されたら、通常、Foreach ループ コンテナーと Foreach ADO 列挙子を使用して、一度に 1 つのレコードセット行を処理します。 Foreach ADO 列挙子によって、現在の行の各列の値が個別のパッケージ変数に保存されます。 その後、Foreach ループ コンテナー内で構成したタスクによって変数から値が読み取られ、その値を使用してアクションが実行されます。

レコードセット変換先は、さまざまなシナリオで使用できます。 次に例をいくつか示します。

  • メール送信タスクと Integration Services 式言語を使用して、レコードセットの行ごとにカスタマイズされた電子メール メッセージを送信できます。

  • データ フロー タスク内で変換元として構成されたスクリプト コンポーネントを使用して、列値をデータ フローの列に読み取ることができます。 その後、変換や変換先を使用して、行を変換および保存できます。 この例では、データ フロー タスクが行ごとに 1 回実行されます。

ここでは、まずレコードセット変換先を使用する一般的な手順について説明し、次に変換先の使用方法の具体的な例を示します。

レコードセット変換先を使用する一般的な手順

次の手順は、レコードセット変換先にデータを保存し、Foreach ループ コンテナーを使用して各行を処理するために必要な手順をまとめたものです。

レコードセット変換先にデータを保存し、Foreach ループ コンテナーを使用して各行を処理するには

  1. SQL Server Data Tools (SSDT)で、Integration Services パッケージを作成または開きます。

  2. レコードセット変換先でメモリに保存されたレコードセットを格納する変数を作成し、変数の型を Objectに設定します。

  3. 使用するレコードセットの各列の値を格納するために、適切な型の追加の変数を作成します。

  4. データ フローで使用するデータ ソースに必要な接続マネージャーを追加して構成します。

  5. データ フロー タスクをパッケージに追加し、SSIS デザイナーの [データ フロー] タブで、データの読み込みおよび変換を行うための変換元および変換を構成します。

  6. レコードセット変換先をデータ フローに追加し、変換に接続します。 レコードセット変換先の VariableName プロパティに、レコードセットを格納するために作成した変数の名前を入力します。

  7. SSIS デザイナーの [制御フロー] タブで、Foreach ループ コンテナーを追加し、このコンテナーをデータ フロー タスクの後に連結します。 [Foreach ループ エディター] を開いて、次の設定を使用してコンテナーを構成します。

    1. [コレクション] ページで、[Foreach ADO 列挙子] をクリックします。 次に、 [ADO オブジェクト ソース変数]で、レコードセットが含まれる変数を選択します。

    2. [変数のマッピング] ページで、使用する各列の 0 から始まるインデックスを適切な変数にマップします。

      ループの各反復処理で、列挙子によってこれらの変数に現在の行の列値が設定されます。

  8. Foreach ループ コンテナー内にタスクを追加し、変数から値を読み取って一度に 1 つのレコードセット行を処理するように構成します。

レコードセット変換先の使用例

次の例では、データ フロー タスクによって AdventureWorks2022 の従業員に関する情報が Sales.SalesPerson テーブルからレコードセット変換先に読み込まれます。 次に、Foreach ループ コンテナーが一度に 1 つのデータ行を読み取って、メール送信タスクを呼び出します。 メール送信タスクは、式を使用して、ボーナス額に関するカスタマイズされた電子メール メッセージを各販売員に送信します。

プロジェクトを作成して変数を構成するには

  1. SQL Server Data Tools で、新しい Integration Services プロジェクトを作成します。

  2. [SSIS] メニューの [変数]をクリックします。

  3. [変数] ウィンドウで、レコードセットと現在の行の列値を格納する変数を作成します。

    1. BonusRecordsetという名前の変数を作成し、その型を Objectに設定します。

      BonusRecordset 変数にはレコードセットが格納されます。

    2. EmailAddressという名前の変数を作成し、その型を Stringに設定します。

      EmailAddress 変数には販売員の電子メール アドレスが格納されます。

    3. FirstNameという名前の変数を作成し、その型を Stringに設定します。

      FirstName 変数には販売員の名が格納されます。

    4. Bonusという名前の変数を作成し、その型を Doubleに設定します。

      Bonus 変数には販売員のボーナス額が格納されます。

接続マネージャーを構成するには

  1. SSIS デザイナーの [接続マネージャー] 領域で、AdventureWorks2022 サンプル データベースに接続する新しい OLE DB 接続マネージャーを追加して構成します。

    この接続マネージャーは、データ フロー タスクの OLE DB ソースがデータを取得するために使用されます。

  2. [接続マネージャー] 領域で、使用可能な SMTP サーバーに接続する新しい SMTP 接続マネージャーを追加して構成します。

    この接続マネージャーは、Foreach ループ コンテナー内のメール送信タスクが電子メールを送信するために使用されます。

データ フローとレコードセット変換先を構成するには

  1. SSIS デザイナーの [制御フロー] タブで、データ フロー タスクをデザイン画面に追加します。

  2. [データ フロー] tab, add an OLE DB source to the [データ フロー] task, and then open the [OLE DB ソース エディター]を開きます。

  3. エディターの [接続マネージャー] ページで、次の設定を使用してソースを構成します。

    1. [OLE DB 接続マネージャー]で、前もって作成した OLE DB 接続マネージャーを選択します。

    2. [データ アクセス モード]で、 [SQL コマンド]を選択します。

    3. [SQL コマンド テキスト]で、次のクエリを入力します。

      SELECT     Person.Contact.EmailAddress, Person.Contact.FirstName, CONVERT(float, Sales.SalesPerson.Bonus) AS Bonus  
FROM         Sales.SalesPerson INNER JOIN  
                      Person.Contact ON Sales.SalesPerson.SalesPersonID = Person.Contact.ContactID

      注意

      Bonus 列の currency 値を Double 型のパッケージ変数に読み込む前に、その値を floatに変換する必要があります。

  4. [データ フロー] タブで、レコードセット変換先を追加し、この変換先を OLE DB ソースの後に連結します。

  5. [レコードセット変換先エディター]を開いて、次の設定を使用して変換先を構成します。

    1. [コンポーネントのプロパティ] タブの VariableName プロパティで、 User::BonusRecordsetを選択します。

    2. [入力列] タブで、使用可能な 3 つすべての列を選択します。

Foreach ループ コンテナーを構成してパッケージを実行するには

  1. SSIS デザイナーの [制御フロー] タブで、Foreach ループ コンテナーを追加し、このコンテナーをデータ フロー タスクの後に連結します。

  2. [Foreach ループ エディター]を開いて、次の設定を使用してコンテナーを構成します。

    1. [コレクション] ページの [列挙子]で [Foreach ADO 列挙子]を選択し、 [ADO オブジェクト ソース変数]で User::BonusRecordsetを選択します。

    2. [変数のマッピング] ページで、 User::EmailAddress をインデックス 0、 User::FirstName をインデックス 1、 User::Bonus をインデックス 2 にマップします。

  3. [制御フロー] タブで、Foreach ループ コンテナー内にメール送信タスクを追加します。

  4. [メール送信タスク エディター]を開いて、 [メール] ページで次の設定を使用してタスクを構成します。

    1. [SmtpConnection]で、前もって構成した SMTP 接続マネージャーを選択します。

    2. [差出人]に、適切な電子メール アドレスを入力します。

      自分の電子メール アドレスを使用すると、パッケージが正常に実行されているかどうかを確認できます。 メール送信タスクによって AdventureWorks2022 の架空の販売員に送信されたメッセージについて、配信不能受領が送られてきます。

    3. [宛先]に、既定の電子メール アドレスを入力します。

      この値は使用されませんが、実行時に各販売員の電子メール アドレスに置き換えられます。

    4. [件名]に、「Your annual bonus」と入力します。

    5. [MessageSourceType]に対して [直接入力]を選択します。

  5. [メール送信タスク エディター] の [式]ページで、参照ボタン ([...]) をクリックして [プロパティ式エディター]を開きます。

  6. [プロパティ式エディター]で、次の情報を入力します。

    1. [ToLine]に、次の式を追加します。

      @[User::EmailAddress]

    2. MessageSource プロパティに、次の式を追加します。

      "Dear " +  @[User::FirstName] + ": The amount of your bonus for this year is $" +  (DT_WSTR, 12) @[User::Bonus] + ". Thank you!"

  7. パッケージを実行します。

    有効な SMTP サーバーと自分のメール アドレスを指定していると、メール送信タスクによって AdventureWorks2022 の架空の販売員に送信されるメッセージについて、配信不能受領が送られてきます。