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

Talend Studioユーザーガイド
Version
Cloud
7.3
Language
日本語
Product
Talend Big Data
Talend Big Data Platform
Talend Cloud
Talend Data Fabric
Talend Data Integration
Talend Data Management Platform
Talend Data Services Platform
Talend ESB
Talend MDM Platform
Talend Real-Time Big Data Platform
Module
Talend Studio
Content
ジョブデザインと開発
Last publication date
2024-03-20

このタスクについて

CDC環境を定義すれば、ソースシステムでデータに加えられた変更を抽出するため、tAS400CDCコンポーネントを使ってTalend Studioでジョブを作成できます。

手順

  1. [Palette] (パレット)からデザインワークスペースにtAS400CDCコンポーネントとtLogRowコンポーネントをドロップし、[Row] (行) > [Main] (メイン)接続を使って両コンポーネントをリンクさせます。
  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>/<Journal_name>) JRNRCV(*GEN)を実行し、ジャーナルから古いレシーバーを分離して新しいレシーバーを作成してそのジャーナルに装着することで、最後の変更を取得できます。

    tAS400CDCコンポーネントは、デフォルトで次のRUNCDCコマンドを実行します。

    <CDC_library_name>/RUNCDC FILE(<Source_library_name>/<Source_table_name>) LIBOUT(<CDC_library_name>) MODE(*DETACHED) MBROPT(*ADD)

    また、tAS400CDCコンポーネントの[Advanced Settings] (詳細設定)ビューで[Customize Command] (コマンドをカスタマイズ)チェックボックスを選択し、次のカスタムコマンドを追加すれば、分離と装着のプロセスを自動化できます。

    <CDC_library_name>/RUNCDC FILE(<Source_library_name>/<Source_table_name>) LIBOUT(<CDC_library_name>) MODE(*DETACHED) MBROPT(*ADD) DTCHJRN(*YES)
    なお、tAS400CDCコンポーネントにあるRUNCDCコマンドのデフォルトセットアップでは1つのテーブルの変更しか読み取りませんのでご注意ください。複数(最大300)のテーブルの変更を同時に読み取ろうとしており、それらのテーブルがすべて同じジャーナルにある場合は、ジョブ内で複数のtAS400CDCコンポーネントを使い、 
    <CDC_library_name>/RUNCDC FILE(<Source_library_name>/<Source_table_name1> <Source_library_name>/<Source_table_name2> ... <Source_library_name>/<Source_table_nameN>) LIBOUT(<CDC_library_name>) MODE(*DETACHED) MBROPT(*ADD)
    というカスタムコマンドを最初のtAS400CDCコンポーネント用に追加します。他のtAS400CDCコンポーネントに対しては、[Advanced settings] (詳細設定)ビューで[Disable Command] (コマンドを無効化)チェックボックスを選択してこのコマンドを無効にします。最初のtAS400CDCコンポーネントによってRUNCDCコマンドが実行され、全ソーステーブルの変更データが抽出されます。その他のtAS400CDCコンポーネントは、最初のtAS400CDCコンポーネントによって準備されたデータを読み取るだけとなります。

    また、どのtAS400CDCコンポーネントについてもコマンドを無効にし、AS/400システムでカスタムコマンドを手動で実行することもできます。

  10. ジョブを保存し、F6を押して実行します。
    コンソールで、[View All Changes] (すべての変更を表示)ダイアログボックスで表示される内容に相当する出力結果を見ることができます。