AS/400ジャーナルモードで変更されたデータを抽出する - Cloud

Talend Cloud Real-Time Big Data Platform Studioユーザーガイド

author
Talend Documentation Team
EnrichVersion
Cloud
EnrichProdName
Talend Cloud
task
ジョブデザインと開発
EnrichPlatform
Talend Management Console
Talend Studio

このタスクについて

CDC環境を定義した後、ソースシステムでデータに加えられた変更を抽出するため、CDC AS/400コンポーネントを使用してTalend Studioでジョブを設計できます。

CDCをAS/400データベースで使用する場合は、次のように進めます。

手順

  1. [Palette] (パレット)から、tAS400CDCおよびtLogRowを設計ワークスペースにドロップし、[Row Main] (行メイン)接続を使用して2つのコンポーネントをリンクします。
  2. tAS400CDCをダブルクリックして、その[Basic settings] (基本設定)を表示します。
  3. [Property type] (プロパティタイプ)ドロップダウンリストから[Repository] (リポジトリー)を選択し、[...]をクリックして、CDC接続に対応するスキーマをフェッチします。それに続くフィールドは、CDCデータベース接続に必要な情報が自動的に入力されます。
  4. [Schema] (スキーマ)ドロップダウンリストから[Repository] (リポジトリー)を選択し、[...]をクリックして、監視対象のAS/400テーブルに対応するスキーマをフェッチします。
  5. [Table Name] (テーブル名)フィールドにCDCによって監視されるソーステーブルの名前(ここでは、CUSTOMERS)を入力します。
  6. [Source Library] (ソースライブラリー)フィールドにソースライブラリーの名前を入力します。デフォルトでは、これはソースデータベースと同じ名前です。
  7. [Subscriber] (サブスクライバ)フィールドに変更されたデータを抽出するサブスクライバの名前を入力します。デフォルトでは、サブスクライバ名はAPP1です。
  8. [Events to catch] (キャッチするイベント)フィールドで、キャッチするイベントに対応するチェックボックスを選択します。
  9. AS/400システムから、 CHGJRN JRN(<Source_library_name>/<Source_table_name>) JRNRCV(*GEN)を実行します
    代わりに、[Advanced settings] (詳細設定)ビューで[Customize FTP command] (FTPコマンドのカスタマイズ)チェックボックスを選択し、次を入力することもできます。
    <CDC_library_name>/RUNCDC FILE(<Source_library_name>/<Source_table_name>) LIBOUT(<CDC_library_name>) MODE(*DETACHED) MBROPT(*ADD) DTCHJRN(*YES)
    このコマンドによって、tAS400CDCは古いレシーバーをジャーナルから切断し、より新しいレシーバーを作成してそのジャーナルに接続できます。
  10. ジョブを保存し、[F6]を押して実行します。

タスクの結果

コンソールで、[View All Changes] (全ての変更を表示)ダイアログボックスで表示される内容に相当する出力結果を見ることができます。