全体の目的
Talendの超簡単なサンプルジョブを作成して，ETLジョブ開発に必要なスキルを習得することが目的です。
対象者
ETL / EAI技術者
環境
| 使用環境 | バージョン |
|---|---|
| OS | Windows10 |
| Talend | 7.1.1 |
サンプル一覧
以下の順番で習得していきます
| # | 内容 |
|---|---|
| 1 | はじめてのTalend |
| 2 | ファイルI/O |
| 3 | データベースI/O |
| 4 | tMap |
| 5 | イテレータ |
| 6 | メタデータ |
| 7 | Context変数 |
| 8 | Global Map |
| 9 | tHashInput/tHashOutput |
| 10 | エラーハンドリング（今回） |
| 11 | ロギング |
| 12 | 子ジョブ（ジョブのネスト） |
| 13-1 | 設定ファイル読み込みオリジナル版 |
| 13-2 | 設定ファイル読み込みコンポ版 |
| 14 | tJava |
今回の目的
エラーハンドリングについて理解する。
3種類のエラーハンドリング
Talendでは3種類のエラーハンドリングが可能です。
| # | 種類 | 説明 |
|---|---|---|
| 1 | Java例外 | JavaのExceptionをキャッチして対処する |
| 2 | [tDie]コンポーネント | [tDie]による処理続行不可エラーをキャッチします。[tDie]は強制終了させたい場合に利用します。 |
| 3 | [tWarn]コンポーネント | [tWarn]によるワーニングをキャッチします。[tWarn]は後続処理を続行できます。 |
サンプルプログラム概要
上記3種類の例外をキャッチするジョブを作り自由にエラーハンドリングができることを確認します。
[tLogCatcher]を利用したジョブ
それではサンプルジョブを作成していきましょう。
リポジトリの[ジョブ]を右クリックし[ジョブの作成]を選択します。
[名前]にerr_handlingと入力し[Finish]ボタンをクリックします。
シンプルなFile出力処理の作成
[tRowGenerator]と[tFileOutputDelimited]を配置します。
[tRowGenerator]コンポーネント上でダブルクリックし設定画面を開きます。
[+]ボタンを一度押下し、ダミーの1カラムだけ定義します。
[tFileOutputDelimited]の出力先ファイル名を設定します。
このサンプルでは "C:/work/err_handling/out.csv" としました。
ロウをつなぎます。
ここまでで一度実行してみましょう。正常に処理されます。
そのまま2度目の実行をしましょう。今度はエラーになるはずです。
The particular file "C:\work\err_handling\out.csv" already exist.
このエラーは[tFileOutputDelimited]の出力モードが新規作成になっている為に出たものです。
この例外をしっかりと対処していきましょう。
例外をキャッチする処理の組み込み
[tLogCatcher]と[tMap]と[tLogRow]を配置します。
[tLogCatcher]と[tMap]をロウでつなぎます。
[tMap]コンポーネント上でダブルクリックし設定画面を開きます。
[+]でout1を作成します。
入力のカラムを全てout1へマッピングしOKで編集画面を閉じます。
[tMap]上で右クリックし、out1を[tLogRow]につなぎます。
[tLogRow]の出力表示モードは見やすくする為「縦に出力」を選んでおきましょう。
それでは実行してみましょう。
先ほどのJava例外を[tLogCatcher]でキャッチし処理していることが確認できます。
例外をコントロールする
ここまででJava例外を処理することはできるようにはなりました。
しかし、これでは全Exceptionをキャッチしているだけでコントロールしているとは言えませんので次はエラー処理を意識して実装してみましょう。
エラーを自分自身で制御するために[tDie]を配置します。
[tRowGenerator]で右クリックし、サブジョブがエラーの場合を選び[tDie]につなぎます。
停止メッセージとエラーコードは下記のように設定します。
| 設定項目 | 設定値 |
|---|---|
| 停止メッセージ | エラーが発生しました |
| 停止コード | 99 |
実行してみましょう。
[tDie]で発生させたエラーを[tLogCatcher]でキャッチし処理していることが確認できます。
終了コードは99で終了しています。
[tDie]の内容を取得できていることが確認できます。
ワーニングをコントロールする
[tLogCatcher]はエラーハンドリングとしてもう一つ[tWarn]をキャッチすることができます。
サンプルで見ていきましょう。まず[tWarn]を配置します。
下記設定にします。
| 設定項目 | 設定値 |
|---|---|
| 警告メッセージ | ファイルの書き出しに成功 |
| コード | 42 |
| 優先度 | 情報 |
[tRowGenerator]で右クリックし、サブジョブがOKの場合を選び[tWarn]につなぎます。
正常系を走らせるので[tFileOutputDelimited]でエラーにならないように追加のチェックを入れておきます。
実行します。
[tLogCatcher]が呼び出されました。
※プライオリティ3は優先度で設定した情報を表しています。
ここで一つ気になることが、終了コードが0となっています。
実は[tWarn]のコードは後続処理で利用できるだけであって、ジョブの終了コードに設定されるわけではありません。
終了コードをコントロールする
例えば準正常の終了コードを0以外の値にするなど、終了コードのコントロールはよく使われます。
最後にTalendでの終了コード設定方法を説明します。
[tJava]を配置します。
[tWarn]からはサブジョブOKでつないだうえで下記コードを設定します。
errorCode = ((Integer)globalMap.get("tWarn_1_WARN_CODE"));
つまりは errorCode という変数を上書きすることで終了コードを制御できます。
実行します。
[tWarn]で定義したコードでジョブを終了していることが確認できます。
まとめ
今回はTalendでのエラーハンドリングを確認しました。
※毎度のことですが、ほんのさわりの部分だけを解説していますのでぜひここから深掘りしてみてください。
お疲れ様でした。
次回以降
次回はロギングをやっていきます。