はじめに
Informatica Intelligent Data Management Cloud(IDMC/旧称IICS)でのちょっとしたTipsを纏めていきます。日々の活動の中で検証した結果記録であり、忘れやすい自分のためのメモですが、少しでも皆様のお役に立てればと思い公開していきます。記述方法など試行錯誤しており随時更新するかもしれません。
この記事のゴール：IDMC データ統合でマッピング間のデータ受け渡しが出来るようになる
マッピング間のデータの受け渡しが出来るといろいろな場面で利用が出来るかもしれません。例えば、ログ出力用共通マッピングタスクがあり、そのログ出力タスクに対してどのマッピングのどのデータタスクでエラーが発生したかを引き渡してログ出力したい、等。
今回はソースAから取得したデータをキーとして、別のマッピングにて別のデータベースのデータを取得すると言う検証をしてみました。
尚この記事の内容は、R43 で検証しています。
具体的な手順
今回実現した処理のイメージは以下の通りです。
- 1つめのマッピングでOracleのDept表から該当のDeptNoを抽出。
- 1つめのマッピングのIn Outパラメータに抽出したDeptNoをセット。
- タスクフローで2つめのマッピングのIn Outパラメータに 1つめのマッピングでセットされたIn Outパラメータの値を渡す。
- 2つめのマッピングでIn Outパラメータを元にSQLServerのEmp表から該当DeptNoのデータを抽出する。
では既に作成した処理(マッピング、マッピングタスク、タスクフロー)を順を追って説明いたします。
1. マッピング01
1-1. In Out パラメータを作成
任意の名称のマッピングを作成したら、パラメータパネルを表示させ、”入出力パラメータ"の新規追加(＋ボタン)をクリック。
以下の設定でIN Outパラメータを設定します。今回は値が文字列だったのでstringを選んでいます。
1-2. In Out パラメータに値を設定
マッピングでの各処理は以下の通り。
2番目の式トランスフォーメーションで、DeptNoのリストを作成します。例えば今回はソーストランスフォーメーションから条件によってDeptNoが 10,10,20,20,20 のような複数の行として引き渡されるとします。
以下のような変数を駆使した処理にてDeptNoをカンマ区切りのリスト化し、最後に o_deptnolist というstring型の出力を後続のトランスフォーメーションに渡します。今回は”10,20"という形でカンマ区切りの文字列が作成され後続に引き渡されます。
3番目の式トランスフォーメーションで、前段で取得し引き渡された o_deptnolist の値をIn Outパラメータ inout_deptnolistに設定しています。
In Outパラメータへ値を設定するにはSetVariable関数を利用します。
これで、マッピング02に値を引き渡すための準備は出来ました。ターゲットの処理はダミー処理のため詳述しませんが、デバッグ用にo_deptnolistをフラットファイルに出力する処理としています。この検証では出力した値は特に利用しませんのでぶっちゃけ何を出力してもよし。マッピングが正常に保存・実行出来ればOKです。
以上で1つめのマッピングが完成したので、マッピングタスクも作成しておきます。マッピングタスクには特に設定すべき内容はないのでそのまま作成しましょう。
2. マッピング02
2-1. In Out パラメータを作成
マッピング01と同様にIn Out パラメータを作成します。名前はm01のパラメータと区別するため inout_deptnolist_m02 としました。
2-2. In Out パラメータを元にソースデータのフィルタリング設定
作成したIn Outパラメータを利用してソースデータのフィルタを設定することにします。マッピング01で作成し引き渡される筈のDeptNoのリストを、クエリオプションの”フィルタ”に設定します。
in句の中身として以下のように記入します。実行時にはパラメータが引き渡され、例えば” EMP.DEPTNO in (10, 20)" のように展開されてソースデータをフィルタ出来ます。
2-3. フィルタされたデータの出力
ターゲットトランスフォーメーションではフィルタリングされた情報をcsvとして出力します。この処理も詳述しませんが、単純に渡された情報を全てターゲットとして出力しています。
以上で2つめのマッピングも完成したので、マッピングタスクも作成しておきます。
3. タスクフロー
最後にタスクフローにしてパラメータの引き渡し処理を設定します。タスクフローを作成し、データタスクを2つ設定、それぞれ作成済みのマッピング01(のマッピングタスク)とマッピング02(のマッピングタスク)を呼び出す設定とします。
ここで設定すべき内容は1つだけ。マッピングタスク02の入力フィールドに存在する”inout_deptnolist_m02"(マッピング02で設定したIn Outパラメータ)に、マッピング01で設定されたIn Outパラメータ”inout_deptnolist"を代入する設定を行います。
具体的には、以下のように、鉛筆アイコンをクリックしEdit画面を開き、
コンテンツを選択して右下の(x)ボタンをクリック。
検索ウィンドウで、マッピング01 の InOut Parameters を展開し、表示される”inout_deptnolist"をクリックし、式が設定されたら”OK”。
タスクフローの設定はこれで終了。保存して実行してみましょう。
実行結果
正常に実行が完了しました。マッピング02ではちゃんとinout_deptnolist_m02に値を受け取れています。
結果ファイルも見てみます。DEPTNOが10と20のEMPデータが抽出できましたので、パラメータの受け渡しが成功しています。
以上、検証結果を記述してみました。何かのお役に立てば幸いです。