コンポーネントと接続を設定 - Cloud - 8.0

Filter (メディエーション)

Version
Cloud
8.0
Language
日本語
Product
Talend Data Fabric
Talend Data Services Platform
Talend ESB
Talend MDM Platform
Talend Real-Time Big Data Platform
Module
Talend Studio
Content
ジョブデザインと開発 > サードパーティーシステム > ルーティングコンポーネント(メディエーション) > フィルターコンポーネント(メディエーション)
データガバナンス > サードパーティーシステム > ルーティングコンポーネント(メディエーション) > フィルターコンポーネント(メディエーション)
データクオリティとプレパレーション > サードパーティーシステム > ルーティングコンポーネント(メディエーション) > フィルターコンポーネント(メディエーション)
Last publication date
2024-02-22

手順

  1. Senderという名前のcFileコンポーネントをダブルクリックし、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開きます。
  2. [Path] (パス)フィールドでメッセージソースへのファイルパスを指定します。
  3. [Encoding] (エンコーディング)リストから、メッセージファイルのエンコーディングタイプを選択します。その他のパラメーターはそのままにしておきます。
  4. cMessageFilterコンポーネントをダブルクリックして、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開きます。
  5. メッセージのフィルタリングに使用する式の言語を選択し、式を入力して、メッセージのフィルタリングに使う条件を定義します。
    このシナリオでは、値がParisの都市ノードを含むXMLファイルをソートするため、[Language] (言語)リストからXPathを選択し、[Expression] (式)フィールドにこの式を入力します: "/person[city='Paris']"
  6. Paris_onlyという名前のcFileコンポーネントをダブルクリックし、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開き、フィルター条件を満たすメッセージのパスを[Path] (パス)フィールドに指定します。
    このステップを繰り返し、送信元からのすべてのメッセージのパスをUnfilteredという名前のcFileコンポーネントに定義します。
  7. Monitor_Parisという名前のcProcessorコンポーネントをダブルクリックし、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開き、[Code] (コード)エリア内のコードをカスタマイズして、フィルター条件を満たすメッセージのファイル名をコンソールに表示します。
    System.out.println("Message sent to folder Paris_only: "+
    exchange.getIn().getHeader("CamelFileName"));
    このステップを繰り返して、Monitor_Unfilteredという名前のcProcessorコンポーネントのコードをカスタマイズし、送信元からのすべてのメッセージのファイル名を表示します。
  8. [Ctrl] + [S]を押してジョブを保存します。