Data Transmission Service (DTS) の抽出・変換・書き出し (ETL) 機能には、ETL タスクキャンバスに追加可能な 3 つの変換コンポーネントがあります。これらは JOIN、Field Calculator、Table Record Filter です。本トピックでは、各コンポーネントの構成方法について説明します。
制限事項
| コンポーネント | 制限事項 |
|---|---|
| JOIN | JOIN 操作は 2 つのテーブル間でのみサポートされます。 |
| Field Calculator | 単一テーブルスキーマのみ対応しています。 |
| Table Record Filter | 単一テーブルスキーマのみ対応しています。 |
前提条件
作業を開始する前に、以下の要件を満たしていることを確認してください。
ソースデータベースが構成済みであること。詳細については、「ソースデータベースの構成」をご参照ください。
ETL キャンバスへのアクセス
すべてのコンポーネントは ETL タスクキャンバスから構成します。キャンバスを開く手順は次のとおりです。
ETL ページに移動します。
Data Management (DMS) コンソールからもこのページにアクセスできます。上部ナビゲーションバーで DTS をクリックし、左側ナビゲーションウィンドウで データ統合 > ストリーミング ETL を選択します。
をクリックし、データフロー名 フィールドに名前を入力し、開発方法 を DAG に設定して、OK をクリックします。左上隅で、ご利用の ETL タスクのリージョンを選択します。
ETL タスクは、次のリージョンでのみ作成できます：中国 (杭州)、中国 (上海)、中国 (青島)、中国 (北京)、中国 (張家口)、中国 (深セン)、および中国 (広州)。
左側ナビゲーションウィンドウで ETL をクリックします。
ETL ページで、タスクの作成 (従量課金) をクリックします。
JOIN コンポーネントの構成
JOIN コンポーネントは、2 つのストリームテーブルからのデータをマージします。内部結合、左結合、右結合の操作をサポートしており、ディメンションテーブルに対する時間的結合 (Temporal Join) も可能です。
ページ左側の 変換 セクションで、JOIN をキャンバス上にドラッグします。
ターゲットデータベース上にポインターを移動し、ドットをクリックしてターゲットデータベースから JOIN コンポーネントへ接続線を引きます。
キャンバス上で JOIN をクリックします。
Transform JOIN セクションで、ノード設定 タブをクリックし、以下のパラメーターを構成します。
時間的結合には、すべてのストリームテーブルに時間属性を定義する必要があります。右テーブルにはプライマリキーが必要です。右テーブルがディメンションテーブルの場合、プライマリキーを結合条件に含める必要があります。
セクション パラメーター 説明 変換名 変換名を入力 識別しやすいようにわかりやすい名前を入力します。名前は一意である必要はありません。 JOIN 設定項目 JOIN 句の左側テーブル JOIN 操作の左側テーブルを選択します。 JOIN 設定項目 時間的結合の時間属性 時間的結合の時間属性を選択します。デフォルト値：Join。オプション：イベント時間ウォーターマークに基づく または 処理時間に基づく。 JOIN 設定項目 JOIN 操作の選択 結合タイプを選択します。各タイプの説明については、下記の表をご参照ください。 結合条件 + 条件を追加 + 条件を追加 をクリックして結合条件を追加します。等号 (=) の左側のフィールドは左側テーブルに属し、右側のフィールドは右テーブルに属します。 JOIN 操作タイプ：
操作 出力 内部結合 2 つのテーブルの共通部分（積集合）のデータが出力されます。 左結合 左側テーブルのデータはそのまま維持され、右テーブルのデータは 2 つのテーブルの共通部分になります。 右結合 左側テーブルのデータは 2 つのテーブルの共通部分になり、右テーブルのデータはそのまま維持されます。 
結合条件を構成したら、出力フィールド タブをクリックします。出力に含める列名を選択し、関連パラメーターを設定します。
Field Calculator コンポーネントの構成
Field Calculator コンポーネントは、既存のデータから式を使用して新しいフィールドを導出します。計算結果をターゲットフィールドに書き込むために使用します。
新 DTS コンソールのデータ移行ページに移動します。
Data Management (DMS) コンソールからもこのページにアクセスできます。上部ナビゲーションバーで DTS をクリックし、左側ナビゲーションウィンドウで DTS (DTS) > データ移行 を選択します。
左上隅で、ご利用の ETL タスクのリージョンを選択します。
ETL タスクは、次のリージョンでのみ作成できます：中国 (杭州)、中国 (上海)、中国 (青島)、中国 (北京)、中国 (張家口)、中国 (深セン)、および中国 (広州)。
左側ナビゲーションウィンドウで ETL をクリックします。
ETL ページで、タスクの作成 (従量課金) をクリックします。
ページ左側の 変換 セクションで、Field Calculator をキャンバス上にドラッグします。
ターゲットデータベース上にポインターを移動し、ドットをクリックしてターゲットデータベースから Field Calculator コンポーネントへ接続線を引きます。
キャンバス上で Field Calculator をクリックします。
Transform Field Calculator セクションで、コンポーネントを構成します。
変換名 セクションで、コンポーネントの名前を入力します。名前は一意である必要はありません。
電卓設定項目 セクションで、+ フィールドを追加 をクリックします。
追加されたフィールドを見つけ、[電卓設定] を [操作] 列でクリックします。
値設定項目 セクションで、以下のパラメーターを構成します。
パラメーター 説明 フィールド名 DTS によりデフォルト名が生成されます。識別しやすいようにわかりやすい名前を入力します。名前は一意である必要はありません。 ETL データ型の選択 計算フィールドの出力データ型を選択します。 ターゲットフィールド：*フィールド名*、値設定項目 ターゲットフィールドの計算式を指定します。直接式を入力するか、フィールド入力、関数セット、または 演算子 セクションのオプションをクリックして式を構築します。 
Table Record Filter コンポーネントの構成
Table Record Filter コンポーネントは、SQL の WHERE 句と同様に条件に基づいて行をフィルターします。条件に一致する行のみがターゲットデータベースに渡されます。
新 DTS コンソールのデータ移行ページに移動します。
Data Management (DMS) コンソールからもこのページにアクセスできます。上部ナビゲーションバーで DTS をクリックし、左側ナビゲーションウィンドウで DTS (DTS) > データ移行 を選択します。
左上隅で、ご利用の ETL タスクのリージョンを選択します。
ETL タスクは、次のリージョンでのみ作成できます：中国 (杭州)、中国 (上海)、中国 (青島)、中国 (北京)、中国 (張家口)、中国 (深セン)、および中国 (広州)。
左側ナビゲーションウィンドウで ETL をクリックします。
ETL ページで、タスクの作成 (従量課金) をクリックします。
ページ左側の 変換 セクションで、Table Record Filter をキャンバス上にドラッグします。
ターゲットデータベース上にポインターを移動し、ドットをクリックしてターゲットデータベースから Table Record Filter コンポーネントへ接続線を引きます。
キャンバス上で Table Record Filter をクリックします。
Transform Table Record Filter セクションで、コンポーネントを構成します。
変換名 セクションで、コンポーネントの名前を入力します。名前は一意である必要はありません。
WHERE 条件 セクションで、フィルター条件を指定します。直接条件を入力するか、フィールド入力 または 演算子 セクションのオプションをクリックして条件を構築します。
構成の確認
変換コンポーネントを構成すると、キャンバス上のコンポーネントの右側に 
アイコンが表示されます。