ソースデータベースを構成する方法について説明します。
前提条件
-
ETL タスクは、次のリージョンでのみ作成できます:中国 (杭州)、中国 (上海)、中国 (青島)、中国 (北京)、中国 (張家口)、中国 (深セン)、中国 (広州)、および中国 (香港)。
-
ソースデータベースは、次のいずれかのタイプである必要があります:MySQL、PolarDB for MySQL、Oracle、PostgreSQL、DB2 for iSeries (AS/400)、DB2 for LUW、PolarDB-X (旧 DRDS)、PolarDB for PostgreSQL、MariaDB、PolarDB for Oracle、SQL Server、または PolarDB-X 2.0。
-
ソースデータベースを作成しました。
操作手順
以下の手順では、MySQL データベースを例として使用します。
-
ストリーミング ETL ページに移動します。
-
DTS コンソールにログインします。
-
左側のナビゲーションウィンドウで、ETL をクリックします。
-
-
左上隅で、
アイコンをクリックします。データフローの作成 ダイアログボックスで、データフロー名 フィールドに名前を入力し、開発方法 を DAG に設定します。 -
確認 をクリックします。
-
左側のペインから、入力/ディメンションテーブル (MySQL) ノードを右側のキャンバスにドラッグします。
-
キャンバス上の 入力 / ディメンションテーブル MySQL-1 ノードをクリックして、ソースデータベースを構成します。
-
ノードの次のパラメーターを設定します。
パラメーター
説明
データソース名
DTS によりデータソースの名前が自動生成されます。識別しやすいように、わかりやすい名前を指定することを推奨します。名前に一意性は必要ありません。
リージョン
ソースデータベースが配置されているリージョンを選択します。
説明ETL タスクは、次のリージョンでのみ利用可能です:中国 (杭州)、中国 (上海)、中国 (青島)、中国 (北京)、中国 (張家口)、中国 (深セン)、中国 (広州)、および中国 (香港)。
インスタンスリスト
ソースデータベースインスタンスを選択します。新しいインスタンスを追加するには、インスタンスの作成 をクリックします。詳細については、「インスタンス管理」をご参照ください。
ノードタイプ
ノードタイプを選択します。
-
ストリームテーブル
-
ディメンションテーブル
変換フォーマット
このパラメーターは、ノードタイプ を ストリームテーブル に設定した場合にのみ表示されます。
-
Upsert ストリーム
-
Append-only ストリーム
データベースとテーブルの選択
変換対象のデータベースおよびテーブルを選択します。
説明データベースおよびテーブルを選択すると、出力フィールド タブが表示されます。
-
-
出力フィールド タブの 列名 列で、必要なフィールドを選択します。
-
オプション:選択したノードタイプが ストリームテーブル の場合、時間属性 タブをクリックして、次のパラメーターを設定し、入力 / ディメンションテーブル MySQL-1 の構成を完了します。
パラメーター
説明
イベントタイムウォーターマークフィールド
データが生成された時刻を示すフィールドを選択します。
イベントタイムウォーターマーク遅延
データ生成の遅延時間を指定します。
処理時間
処理時間のフィールド名を入力します。
-
結果
ソースデータベースノードの右側に アイコンが表示されない場合、構成は正常に完了しています。