PolarDB 出力コンポーネントは、PolarDB データソースにデータを書き込みます。他のデータソースから PolarDB データソースにデータを同期する場合、ソースデータソース情報とターゲット PolarDB データソースの両方を構成する必要があります。このトピックでは、PolarDB 出力コンポーネントを構成する方法について説明します。
前提条件
PolarDB データソースを作成済みであること。詳細については、「PolarDB データソースを作成する」をご参照ください。
PolarDB 出力コンポーネントのプロパティを構成するために使用するアカウントに、データソースに対するライトスルー権限があること。この権限がない場合は、申請する必要があります。詳細については、「データソース権限の申請、更新、および返却」をご参照ください。
手順
Dataphin ホームページの上部ナビゲーションバーで、[開発] > [Data Integration] を選択します。
統合ページの上部ナビゲーションバーで、[プロジェクト] を選択します (Dev-Prod モードでは、[環境] を選択します)。
左側のナビゲーションウィンドウで、[バッチパイプライン] をクリックします。[バッチパイプライン] リストで、開発する オフラインパイプライン をクリックして、その構成ページを開きます。
ページの右上隅にある [コンポーネントライブラリ] をクリックして、[コンポーネントライブラリ] パネルを開きます。
[コンポーネントライブラリ] パネルの左側のナビゲーションウィンドウで、[出力] を選択します。右側の出力コンポーネントリストで [PolarDB] コンポーネントを見つけ、キャンバスにドラッグします。
ターゲットの入力、変換、またはフローコンポーネントの
アイコンをクリックしてドラッグし、現在の PolarDB 出力コンポーネントに接続します。PolarDB 出力コンポーネントカードの
アイコンをクリックして、[PolarDB 出力構成] ダイアログボックスを開きます。
[PolarDB 出力構成] ダイアログボックスで、パラメーターを構成します。
パラメーター
説明
[基本設定]
[ステップ名]
PolarDB 出力コンポーネントの名前。Dataphin は自動的にステップ名を生成しますが、ビジネスシナリオに基づいて変更できます。名前は次の要件を満たしている必要があります。
中国語の文字、英字、アンダースコア (_)、および数字のみを含めることができます。
長さは 64 文字を超えることはできません。
データソース
データソースのドロップダウンリストには、ライトスルー権限を持つデータソースと持たないデータソースを含め、すべての PolarDB データソースが表示されます。
アイコンをクリックして、現在のデータソース名をコピーします。ライトスルー権限のないデータソースの場合、データソースの横にある [リクエスト] をクリックして、ライトスルー権限を申請できます。詳細については、「データソース権限の申請、更新、および返却」をご参照ください。
PolarDB データソースがない場合は、[データソースの作成] をクリックして作成します。詳細については、「PolarDB データソースを作成する」をご参照ください。
タイムゾーン
コンポーネントは、現在のタイムゾーンに基づいて時間形式のデータを処理します。デフォルトでは、タイムゾーンは選択したデータソースから継承され、変更できません。
説明V5.1.2 より前に作成されたノードの場合、[データソースのデフォルト設定] または [チャネル設定のタイムゾーン] を選択できます。デフォルトでは、[チャネル設定のタイムゾーン] が選択されています。
データソースのデフォルト設定: 選択したデータソースのデフォルトのタイムゾーン。
チャネル設定のタイムゾーン: 現在の統合ノードの [プロパティ] > [チャネル設定] で構成されたタイムゾーン。
テーブル
出力データのターゲットテーブルを選択します。 キーワードを入力してテーブルを検索するか、正確なテーブル名を入力して [完全一致] をクリックします。テーブルを選択すると、システムは自動的にテーブルステータスを確認します。
アイコンをクリックして、選択したテーブルの名前をコピーします。読み込みポリシー
ターゲットテーブルにデータを書き込むためのポリシーを選択します。ロードポリシー には以下が含まれます。
[データの追加]：既存データを変更せずに、ターゲットテーブルの既存データにデータを追加します。プライマリキーまたは制約違反が発生した場合、ダーティデータエラーが報告されます。
[データの上書き]：プライマリキーまたは制約違反が発生した場合、システムは最初に重複するプライマリキーを持つ古いデータの行全体を削除し、次に新しいデータを挿入します。
説明ロードポリシーは、PostgreSQL プロトコルでは有効になりません。
バッチ書き込みサイズ（オプション）
一度に書き込まれるデータのサイズです。[バッチ書き込みレコード] も設定できます。いずれかの制限に達すると、システムはデータを書き込みます。デフォルト値は 32M です。
バッチ書き込みレコード（オプション）
デフォルト値は 2048 レコードです。データが同期および書き込みされるとき、バッチ書き込み戦略が使用され、[バッチ書き込みレコード] と [バッチ書き込みサイズ] などのパラメーターが含まれます。
累積データがいずれかの制限（バッチ書き込みサイズまたはレコード数）に達すると、システムはデータのバッチがいっぱいになったと見なし、このバッチデータをすぐに宛先に一度に書き込みます。
バッチ書き込みサイズを 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 );
新しい出力フィールドを作成する：[+ 出力フィールドの作成] をクリックし、プロンプトに従って [列] に入力し、[タイプ] を選択します。現在の行の構成が完了したら、
アイコンをクリックして保存します。
[マッピング]
上流の入力とターゲットテーブルのフィールドに基づいて、フィールドマッピングを手動で選択できます。マッピング には、[同じ行のマッピング] と [同じ名前のマッピング] が含まれます。
同じ名前のマッピング：同じ名前のフィールドをマッピングします。
同じ行のマッピング：ソーステーブルとターゲットテーブルのフィールド名が異なるが、対応する行のデータをマッピングする必要がある場合、同じ行のフィールドをマッピングします。
[OK] をクリックして、[PolarDB] 出力コンポーネントのプロパティ構成を完了します。