GoldenDB 出力コンポーネントは、データを GoldenDB データソースに書き込みます。他のデータソースから GoldenDB データソースへデータを同期する場合、まずソースデータソースの情報を構成した後、GoldenDB 出力コンポーネントのターゲット(対象)データソースを設定する必要があります。本トピックでは、GoldenDB 出力コンポーネントの設定方法について説明します。
前提条件
GoldenDB データソースを作成済みである必要があります。詳細については、「GoldenDB データソースの作成」をご参照ください。
GoldenDB 出力コンポーネントのプロパティを設定する際に使用するアカウントが、当該データソースに対してライトスルー権限を有している必要があります。権限がない場合は、データソースの権限申請が必要です。詳細については、「データソースの権限申請」をご参照ください。
操作手順
Dataphin ホームページの上部ナビゲーションバーで、[開発] > [データ統合] を選択します。
統合ページの上部ナビゲーションバーで、[プロジェクト] を選択します(Dev-Prod モードの場合は、[環境] を選択します)。
左側のナビゲーションウィンドウで、[バッチパイプライン] をクリックします。[バッチパイプライン] 一覧から、開発対象の [オフラインパイプライン] をクリックし、その構成ページを開きます。
ページ右上隅の [コンポーネントライブラリ] をクリックして、[コンポーネントライブラリ] パネルを開きます。
[コンポーネントライブラリ] パネルの左側ナビゲーションウィンドウで、[出力] を選択します。右側の出力コンポーネント一覧から GoldenDB コンポーネントを見つけ、キャンバスにドラッグします。
対象となる入力・変換・フロー各コンポーネントの
アイコンをクリックしてドラッグし、現在の GoldenDB 出力コンポーネントに接続します。GoldenDB 出力コンポーネント上で
アイコンをクリックして、[GoldenDB 出力構成] ダイアログボックスを開きます。
[GoldenDB 出力構成] ダイアログボックスで、パラメーターを設定します。
パラメーター
説明
基本設定
ステップ名
GoldenDB 出力コンポーネントの名称です。Dataphin が自動的にステップ名を生成しますが、ビジネスシナリオに応じて変更可能です。名称には以下の要件があります:
中国語文字、英字、アンダースコア(_)、数字のみ使用できます。
最大 64 文字までです。
データソース
データソースのドロップダウンリストには、ライトスルー権限を有するものおよび権限を持たないすべての GoldenDB データソースが表示されます。
アイコンをクリックすると、現在のデータソース名をコピーできます。ライトスルー権限を持たないデータソースについては、データソース横の [申請] をクリックして権限を申請できます。詳細については、「データソースの権限申請」をご参照ください。
GoldenDB データソースが存在しない場合は、[データソースの作成] をクリックして新規作成してください。詳細については、「GoldenDB データソースの作成」をご参照ください。
テーブル
出力データの対象テーブルを選択します。 テーブル名のキーワードを入力して検索するか、正確なテーブル名を入力して [完全一致] をクリックしてください。テーブルを選択後、システムが自動的にテーブルの状態を確認します。
アイコンをクリックすると、現在選択中のテーブル名をコピーできます。読み込みポリシー
ターゲットデータソース(GoldenDB データソース)のテーブルへのデータ書き込みポリシーです。ローディングポリシーには「上書き」と「追加」があります。適用シナリオは以下のとおりです:
[データの追加]:プライマリキーまたは制約違反が発生した場合、ダーティデータエラーが通知されます。
[データの上書き]:プライマリキーまたは制約違反が発生した場合、システムはまず既存のデータを削除し、その後新しいレコード全体を挿入します。
バッチ書き込みサイズ(任意)
一度に書き込むデータ量です。[バッチ書き込み件数] も設定可能です。データ書き込み時には、いずれかの上限値(バッチ書き込みサイズまたは件数)に先に達した時点で書き込みが実行されます。デフォルト値は 32 MB です。
バッチ書き込み件数(任意)
デフォルト値は 2048 件 です。データ同期および書き込み時には、[バッチ書き込み件数] および [バッチ書き込みサイズ] をパラメーターとするバッチ書き込み戦略が採用されます。
累積されたデータがいずれかの設定上限(バッチ書き込みサイズまたは件数)に達すると、システムはそのデータを 1 バッチとして満了と判断し、即座にターゲットへ一括書き込みを行います。
バッチ書き込みサイズは、推奨値として 32 MB を設定することを推奨します。バッチ挿入件数の上限については、単一レコードの実際のサイズに応じて柔軟に調整できます。通常は、バッチ書き込みのメリットを十分に活用できるよう、より大きな値を設定します。例えば、単一レコードのサイズが約 1 KB の場合、バッチ挿入バイトサイズを 16 MB とし、この条件に基づいてバッチ挿入件数を 16 MB ÷ 1 KB(=16384 件)より大きい値(例: 20000 件)に設定します。この構成では、システムはバッチ挿入バイトサイズに基づいて書き込みをトリガーし、累積データが 16 MB に達するごとに書き込み操作を実行します。
プリペアドステートメント(任意)
データインポート前にデータベース上で実行される SQL スクリプトです。
例:サービスの継続的な可用性を確保するために、現在のステップによるデータ書き込み前に、まずターゲットテーブル Target_A を作成し、Target_A への書き込みを実行します。現在のステップによる書き込み完了後、継続的に稼働中のテーブル Service_B を Temp_C にリネームし、その後 Target_A を Service_B にリネームし、最後に Temp_C を削除します。
ポストステートメント(任意)
データインポート後にデータベース上で実行される SQL スクリプトです。
フィールドマッピング
入力フィールド
上流コンポーネントの出力に基づいて表示される入力フィールドです。
出力フィールド
出力フィールドを表示します。以下の操作が可能です:
フィールド管理: [フィールド管理] をクリックして出力フィールドを選択します。

アイコンをクリックして、[選択済み入力フィールド] を [未選択入力フィールド] に移動します。
アイコンをクリックして、[未選択の入力フィールド] を [選択済みの入力フィールド] に移動します。
一括追加: [一括追加] をクリックして、JSON、TEXT、DDL 形式で構成します。
JSON 形式での一括構成の例:
// 例: [{ "name": "user_id", "type": "String" }, { "name": "user_name", "type": "String" }]説明`name` はインポート対象のフィールド名、`type` はインポート後のフィールドのデータの型です。たとえば、
"name":"user_id","type":"String"は `user_id` という名前のフィールドをインポートし、そのデータの型を `String` に設定します。TEXT 形式での一括構成の例:
// 例: user_id,String user_name,String行区切り文字は各フィールドの情報を分離します。デフォルトは改行(\n)ですが、改行(\n)、セミコロン(;)、ピリオド(.)をサポートします。
列区切り文字はフィールド名とデータの型を分離します。デフォルトはカンマ(,)です。
DDL 形式での一括構成の例:
CREATE TABLE tablename ( id INT PRIMARY KEY, name VARCHAR(50), age INT );
新しい出力フィールドの作成: [+新しい出力フィールドの作成] をクリックし、[列] を入力し、[型] を指定します。現在の行の構成を完了したら、
アイコンをクリックして保存します。
マッピング
上流の入力フィールドとターゲットテーブルのフィールドに基づき、手動でフィールドマッピングを選択できます。[マッピング] には [同一行マッピング] および [同一名称マッピング] があります。
[同一名称マッピング]: 名称が一致するフィールドをマッピングします。
[同一行マッピング]: ソーステーブルとターゲットテーブルのフィールド名が異なるものの、対応する行のデータをマッピングする必要がある場合に使用します。
[確認] をクリックして、GoldenDB 出力コンポーネント のプロパティ構成を完了します。