すべてのプロダクト
Search

このプロダクト

    Dataphin:openGauss 出力コンポーネントの構成

    ドキュメントセンター

    Dataphin:openGauss 出力コンポーネントの構成

    最終更新日:Mar 01, 2026

    openGauss 出力コンポーネントは、openGauss データソースにデータを書き込みます。他のデータソースからのデータを openGauss データソースに同期するシナリオでは、ソースデータソース情報を構成した後、openGauss 出力コンポーネントのターゲットデータソースを構成してデータを書き込む必要があります。このトピックでは、openGauss 出力コンポーネントの構成方法について説明します。

    前提条件

    • openGauss データソースを作成済みであること。詳細については、「openGauss データソースの作成」をご参照ください。

    • openGauss 入力コンポーネントのプロパティを構成するために使用するアカウントには、データソースに対するライトスルー権限が必要です。権限がない場合は、データソース権限をリクエストする必要があります。詳細については、「データソース権限のリクエスト」をご参照ください。

    操作手順

    1. Dataphin ホームページのトップナビゲーションバーで、[開発] ＞ [データ統合] を選択します。

    2. Integration ページのトップナビゲーションバーで、[Project] を選択します (Dev-Prod モードでは、[Environment] を選択する必要があります)。

    3. 左側のナビゲーションウィンドウで、[バッチパイプライン] をクリックし、[バッチパイプライン] リストで開発する [オフラインパイプライン] をクリックして、オフラインパイプラインの構成ページを開きます。

    4. ページの右上隅の [コンポーネントライブラリ] をクリックして、[コンポーネントライブラリ] パネルを開きます。

    5. [コンポーネントライブラリ] パネルの左側にあるナビゲーションウィンドウで、[出力] を選択し、右側の出力コンポーネントリストで [openGauss] コンポーネントを見つけ、コンポーネントをキャンバスにドラッグします。

    6. ターゲットの入力、変換、またはフローコンポーネントの image アイコンをクリックしてドラッグし、現在の openGauss 出力コンポーネントに接続します。

    7. openGauss 出力コンポーネントの image アイコンをクリックして、[openGauss 出力設定] ダイアログボックスを開きます。image

    8. [OpenGauss 出力設定] ダイアログボックスで、パラメーターを設定します。

      パラメーター

      説明

      基本設定

      Step Name

      openGauss 出力コンポーネントの名前。Dataphin はステップ名を自動的に生成します。ビジネスシナリオに基づいて変更できます。名前は次の要件を満たす必要があります。

      • 中国語文字、英字、アンダースコア (_)、および数字のみを含めることができます。

      • 長さは 64 文字を超えることはできません。

      Datasource

      データソースのドロップダウンリストには、ライトスルー権限を持つデータソースとライトスルー権限を持たないデータソースを含む、すべての openGauss データソースが表示されます。image アイコンをクリックして、現在のデータソース名をコピーします。

      • ライトスルー 権限を持っていないデータソースについては、データソースの横にある [リクエスト] をクリックして、そのデータソースのライトスルー 権限をリクエストできます。詳細については、「データソースの権限をリクエストする」をご参照ください。

      • openGauss データソースがない場合は、[データソースの作成] をクリックしてデータソースを作成します。詳細については、「openGauss データソースの作成」をご参照ください。。

      Schema

      スキーマは、データソース内のテーブルが属するプロジェクトに相当します。

      Table

      出力データのターゲットテーブルを選択します。

      説明

      コピーモードではビューはサポートされていません。

      openGauss データソースにデータ同期用のターゲットテーブルがない場合は、ワンクリックターゲットテーブル生成機能を使用してターゲットテーブルを迅速に生成できます。詳細な操作手順は次のとおりです。

      1. 「[ワンクリックでターゲットテーブルを生成]」をクリックします。Dataphin は、ターゲットテーブルを作成するためのコードを自動的にマッチングします。これには、ターゲットテーブル名（デフォルトはソーステーブル名）、フィールドタイプ（Dataphin フィールドに基づいて初期変換されます）、およびその他の情報を含みます。次の図に例を示します：

        image

      2. 必要に応じて、ターゲットテーブルを作成するためのSQL スクリプトを変更し、次に [作成] をクリックできます。

        ターゲットテーブルが作成されると、Dataphin は新しく作成されたテーブルを自動的に出力データのターゲットテーブルとして設定します。ワンクリックターゲットテーブル生成機能は、開発環境と本番環境でデータ同期用のターゲットテーブルを作成するために使用されます。Dataphin は、デフォルトでテーブル作成に本番環境を選択します。本番環境に同じ名前と構造のテーブルがすでに存在する場合、本番環境でのテーブル作成を選択する必要はありません。

        説明

        開発環境または本番環境に同じ名前のテーブルが存在する場合、[Create] をクリックすると、Dataphin はテーブルがすでに存在することを示すエラーを報告します。

      Loading Policy

      ターゲットテーブルへのデータ書き込みに使用するポリシーを選択します。[ローディングポリシー] には以下が含まれます:

      • データの上書き: ターゲットテーブル内の既存データを、現在のソーステーブルに基づいて上書きします。

      • データの追加: ターゲットテーブルの既存データは変更せず、データを追加します。

      • コピー: テーブルとファイル間のコピーに使用されます。 競合が発生した場合、システムは [競合解決ポリシー] に従って、[競合時にエラーを報告] または [競合時に上書き] のいずれかで処理します。

      バッチ書き込みデータ量

      一度に書き込まれるデータのサイズです。[バッチ書き込み数] も設定できます。データ書き込みは、いずれかの制限値に先に達した時点で行われます。デフォルト値は 32M です。

      バッチ書き込み数

      デフォルト値は 2048 レコード です。データ同期および書き込み中に、バッチ書き込み戦略が使用され、パラメーターには [バッチ書き込み数] と [バッチ書き込みデータ量] が含まれます。

      • 累積データ量が設定された制限 (つまり、バッチ書き込みデータ量または数制限) のいずれかに達すると、システムはデータバッチが満杯であるとみなし、このデータバッチをターゲットエンドに一度に書き込みます。

      • バッチ書き込みデータ量を 32MB に設定することを推奨します。バッチ挿入数制限については、単一レコードの実際のサイズに基づいて柔軟に調整できます。通常、バッチ書き込みの利点を最大限に活用するために、より大きな値を設定します。たとえば、単一レコードのサイズが約 1KB の場合、バッチ挿入バイトサイズを 16MB に設定し、この条件を考慮して、バッチ挿入数を 16MB を 1KB の単一レコードサイズで割った結果 (つまり、16384 レコードより大きい値) よりも大きい値に設定します。ここでは 20000 レコードに設定されていると仮定します。この構成では、システムはバッチ挿入バイトサイズに基づいてバッチ書き込み操作をトリガーし、累積データ量が 16MB に達するたびに書き込み操作を実行します。

      フィールドマッピング

      Input Fields

      アップストリームコンポーネントの出力に基づいて入力フィールドを表示します。

      Output Fields

      出力フィールドを表示します。次の操作を実行できます。

      • フィールド管理: [フィールド管理] をクリックして、出力フィールドを選択します。

        image

        • gaagag アイコンをクリックして、[選択済み入力フィールド] を [未選択入力フィールド] に移動します。

        • agfag アイコンをクリックして、[未選択の入力フィールド] を [選択済みの入力フィールド] に移動します。

      • バッチ追加: [バッチ追加] をクリックして、JSON、TEXT フォーマット、および DDL フォーマットでのバッチ構成をサポートします。

        • JSON 形式でのバッチ構成の例:

          // Example:
[{
  "name": "user_id",
  "type": "String"
 },
 {
  "name": "user_name",
  "type": "String"
 }]
          説明

          `name` はインポートするフィールドの名前を指定します。`type` はインポート後のフィールドのタイプを指定します。たとえば、"name":"user_id","type":"String" は `user_id` という名前のフィールドをインポートし、そのタイプを `String` に設定します。

        • TEXT 形式でのバッチ構成の例:

          // Example:
user_id,String
user_name,String

          • 行区切り文字は、各フィールドの情報を区切るために使用され、デフォルトは改行 (\n) です。改行 (\n)、セミコロン (;) 、およびピリオド (.) をサポートします。

          • 列区切り文字は、フィールド名とフィールドタイプを区切るために使用され、デフォルトはカンマ (,) です。

        • DDL 形式でのバッチ構成の例:

          CREATE TABLE tablename (
    id INT PRIMARY KEY,
    name VARCHAR(50),
    age INT
);

      • 出力フィールドの新規作成: [+出力フィールドの新規作成] をクリックし、ページの指示に従って [列] に入力し、[タイプ] を選択します。現在の行の構成が完了したら、image アイコンをクリックして保存します。

      Mapping

      上流の入力とターゲットテーブルのフィールドに基づいて、フィールドマッピングを手動で選択できます。 [クイックマッピング] には [同一行マッピング] と [同一名マッピング] が含まれます。

      • [Same name mapping]: 同名のフィールドをマッピングします。

      • [Same row mapping]: ソーステーブルとターゲットテーブルのフィールド名が不一致ですが、フィールドの対応する行のデータをマッピングする必要があります。同じ行のフィールドのみをマッピングします。

    9. [OK] をクリックして、[OpenGauss 出力コンポーネント] のプロパティ構成を完了します。