GBase 8a 出力コンポーネントは、GBase 8a データソースにデータを書き込みます。 他のデータソースから GBase 8a データソースにデータを同期する場合、ソースデータソース情報を構成した後、GBase 8a 出力コンポーネントのターゲットデータソースを構成する必要があります。 このトピックでは、GBase 8a 出力コンポーネントを構成する方法について説明します。
前提条件
GBase 8a データソースを追加済みであること。 詳細については、「GBase 8a データソースを作成する」をご参照ください。
GBase 8a 出力コンポーネントのプロパティを構成するために使用するアカウントが、データソースに対するライトスルー権限を持っていること。 権限がない場合は、データソース権限をリクエストする必要があります。 詳細については、「データソース権限のリクエスト、更新、および返却」をご参照ください。
手順
Dataphin ホームページの上部ナビゲーションバーで、[開発] > [Data Integration] を選択します。
変更を保存環境統合ページの上部ナビゲーションバーで、 を選択します(開発-本番モードでは、 を選択する必要があります)。
左側のナビゲーションウィンドウで、[バッチパイプライン]オフライン パイプライン をクリックし、[バッチパイプライン] リストで開発するオフラインパイプラインをクリックして、オフラインパイプラインの構成ページを開きます。
ページの右上隅にある [コンポーネントライブラリ] をクリックして、[コンポーネントライブラリ] パネルを開きます。
[コンポーネントライブラリ] パネルの左側のナビゲーションウィンドウで、[出力] を選択し、右側の出力コンポーネントリストで [GBase 8a] コンポーネントを見つけて、キャンバスにドラッグします。
ターゲット入力、変換、またはフローコンポーネントの
アイコンをクリックしてドラッグし、現在の GBase 8a 出力コンポーネントに接続します。GBase 8a 出力コンポーネントカードの
アイコンをクリックして、[GBase 8a 出力構成] ダイアログボックスを開きます。
[GBase 8a 出力構成] ダイアログボックスで、パラメーターを構成します。
パラメーター
説明
基本設定
ステップ名
GBase 8a 出力コンポーネントの名前。 Dataphin は自動的にステップ名を生成しますが、ビジネス要件に基づいて変更できます。 名前は次の要件を満たしている必要があります。
漢字、英字、アンダースコア(_)、および数字のみを含めることができます。
長さは 64 文字を超えることはできません。
データソース
データソースドロップダウンリストには、ライトスルー権限を持っているデータソースとライトスルー権限を持っていないデータソースを含む、すべての GBase 8a データソースが表示されます。
アイコンをクリックして、現在のデータソース名をコピーします。ライトスルー権限を持っていないデータソースの場合、データソースの横にある [リクエスト] をクリックして、データソースのライトスルー権限をリクエストできます。 詳細については、「データソース権限のリクエスト」をご参照ください。
GBase 8a データソースがない場合は、[データソースの作成] をクリックしてデータソースを作成します。 詳細については、「GBase 8a データソースを作成する」をご参照ください。
テーブル
出力データのターゲットテーブルを選択します。 キーワードを入力してテーブルを検索するか、正確なテーブル名を入力して [完全一致] をクリックします。 テーブルを選択すると、システムは自動的にテーブルステータスをチェックします。
アイコンをクリックして、選択したテーブルの名前をコピーします。ロードポリシー
ターゲットテーブルにデータを書き込むためのポリシーを選択します。 ロードポリシーは [データの追加] をサポートしています。 プライマリキーまたは制約違反が発生した場合、ダーティデータエラーが報告されます。
バッチ書き込みデータ量(オプション)
一度に書き込むデータのサイズ。 [バッチ書き込みレコード] を設定することもできます。 2 つの制限のいずれかに達すると、システムはデータを書き込みます。 デフォルト値は 32M です。
バッチ書き込みレコード(オプション)
デフォルト値は 2048 レコードです。 データが同期および書き込まれる場合、バッチ書き込み戦略が使用されます。 パラメーターには、[バッチ書き込みレコード] と [バッチ書き込みデータ量] が含まれます。
累積データ量が 2 つの制限(バッチ書き込みデータ量またはバッチ書き込みレコード)のいずれかに達すると、システムはデータのバッチが累積されたと見なし、バッチデータを一度に宛先に書き込みます。
バッチ書き込みデータ量を 32 MB に設定することをお勧めします。 バッチ書き込みレコードの上限については、1 レコードの実際のサイズに基づいて調整できます。 通常、バッチ書き込みの利点を最大限に活用するために、大きな値に設定します。 たとえば、1 レコードのサイズが約 1 KB の場合、バッチ書き込みデータ量を 16 MB に設定できます。 この条件を考慮して、バッチ書き込みレコードを 16 MB を 1 レコードのサイズ 1 KB で割った結果よりも大きい値(つまり、16,384 レコードより大きい値)、たとえば 20,000 レコードに設定します。 この構成の後、システムはバッチ書き込みデータ量に基づいてバッチ書き込みをトリガーします。 累積データ量が 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] をクリックして、[GBase 8a 出力コンポーネント] のプロパティ構成を完了します。