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