DataWorks:フィールドの編集と値の割り当て

操作手順 1：データ統合タスクの構成

1. データソースを作成します。詳細については、「データソースの管理」をご参照ください。

2. データ統合タスクを作成します。詳細については、「単一テーブルリアルタイム同期タスクの構成」をご参照ください。

   説明

   Data Integration の単一テーブルリアルタイム同期タスクでは、ソースノードと宛先ノードの間にデータ処理ノードを追加できます。詳細については、「対応するデータソースおよび同期ソリューション」をご参照ください。

操作手順 2：フィールドの編集と値の割り当ての追加

1. リアルタイム単一テーブル同期タスクの構成画面で、[データ処理] スイッチを有効化し、[ノードの追加] をクリックして、「フィールドの編集と値の割り当て」コンポーネントを選択します。

2. 「フィールドの編集と値の割り当て」コンポーネントを構成します。

   

   • 上流フィールド

     • フィールド名：上流出力から取得されるフィールドの名称です。

     • 型：上流出力から取得されるフィールドのデータの型です。

     • 値：既存の上流フィールドについては、上流出力から値が継承されます。新規フィールドについては、値の生成方法を指定します。「割り当て」「変数」「関数」の 3 つの方法から選択できます。

     • アクション：フィールドを下流コンポーネントに渡すかどうかを決定します。

   • カスタムフィールド：「フィールドの編集と値の割り当て」ページ左下の [フィールドの追加] をクリックして、新規フィールドを追加します。

     • [割り当て]：入力した定数を新規フィールドに割り当てます。この定数は、指定されたデータの型に変換されます。

     • [変数]：実行時に組み込み変数の値を新規フィールドに割り当てます。サポートされる組み込み変数の一覧を以下に示します。

       説明

       変数のサポート状況は、ソースおよび宛先の具体的な特性に依存します。

       サポートされる変数

       変数名		説明
       ソース	PROCESS_TIME	同期タスクがレコードを処理する時刻です。13 桁のミリ秒タイムスタンプです。
       	DATASOURCE_NAME_SRC	ソースデータソースの名称です。
       	DB_NAME_SRC	ソースデータベースの名称です。
       	SCHEMA_NAME_SRC	ソーススキーマの名称です。
       	TABLE_NAME_SRC	ソーステーブルの名称です。
       	TOPIC_NAME_SRC	ソーストピックの名称です。
       宛先	TABLE_NAME_DEST	宛先テーブルの名称です。
       	TOPIC_NAME_DEST	宛先トピックの名称です。
       	SCHEMA_NAME_DEST	宛先スキーマの名称です。
       	DB_NAME_DEST	宛先データベースの名称です。
       	DATASOURCE_NAME_DEST	宛先データソースの名称です。

     • [関数]：同期中に関数計算を実行し、その結果を新規フィールドに割り当てます。関数処理中に例外が発生した場合、該当レコードはダーティデータとして扱われ、同期タスクのダーティデータ統計にカウントされ、ダーティデータ許容設定に基づいてタスクが終了する可能性があります。

       サポートされる関数

       関数名	パラメーター	説明
       DATE_FORMAT	パラメーター 1：数値型の上流フィールドで、10 桁の UNIX タイムスタンプまたは 13 桁のミリ秒タイムスタンプを指定できます。 パラメーター 2：タイムスタンプの種類です。unix は 10 桁の UNIX タイムスタンプを、millis は 13 桁のミリ秒タイムスタンプを表します。 パラメーター 3：変換に使用するタイムゾーンです。 パラメーター 4：目的の日付文字列フォーマット（例：yyyy-MM-dd HH:mm:ss:SSS ZZ）。yyyy は年、MM は月、dd は日、HH は時（24 時間表記）、mm は分、ss は秒、SSS はミリ秒、ZZ はタイムゾーンを表します。	タイムスタンプを特定のフォーマットの時刻文字列に変換します。
       TO_TIMESTAMP	パラメーター 1：テキスト型の上流フィールドで、特定のフォーマットの時刻文字列を表します。 パラメーター 2：目的のタイムスタンプの種類です。unix は 10 桁の UNIX タイムスタンプを、millis は 13 桁のミリ秒タイムスタンプを表します。 パラメーター 3：変換に使用するタイムゾーンです。 パラメーター 4：時刻文字列のフォーマット（例：yyyy-MM-dd HH:mm:ss:SSS ZZ）。yyyy は年、MM は月、dd は日、HH は時（24 時間表記）、mm は分、ss は秒、SSS はミリ秒、ZZ はタイムゾーンを表します。	時刻文字列を 10 桁または 13 桁のタイムスタンプに変換します。
       SUBSTRING	パラメーター 1：テキスト型の上流フィールドです。 パラメーター 2：部分文字列の開始位置（包含）です。最小の開始位置は 0 です。 パラメーター 3：部分文字列の長さです。長さが 0 以下の場合、開始位置から末尾までの部分文字列が返されます。	文字列から部分文字列を抽出します。

次のステップ

データソースおよびフィールドの編集・値の割り当ての構成後、[データ出力プレビュー] をクリックして、現在のノードの出力データが要件を満たしているか確認できます。新規フィールドは、フィールドマッピングで宛先テーブルのフィールドにマップされた後にのみ、宛先テーブルに書き込まれます。