目次

Search

  1. はじめに
  2. タスクフローとリニアタスクフロー
  3. タスクフロー
  4. リニアタスクフロー

タスクフロー

タスクフロー

データタスクステップ

データタスクステップ

データタスクステップを追加するときに、いくつかのプロパティを設定します。
次のセクションでは、データタスクステップのプロパティについて説明します。

全般

全般プロパティで、データタスクステップにわかりやすい名前を指定できます。
名前には、英数字、アンダースコア(_)、スペース、およびUnicode文字のみを含めることができます。

データタスク

データタスクステップのプロパティで、タスクフローに追加するタスクを、既存のタスクリストから選択します。
タスクフローに追加する既存のタスクが必要です。タスクフロー作成プロセスでタスクを作成することはできません。
マッピングタスクをデータタスクステップに追加すると、説明、入力フィールド、および出力フィールドが表示されます。入力フィールドには、マッピングタスクが使用する入出力パラメータが表示されます。出力フィールドには、タスクフローの実行後にマッピングタスクが返す出力フィールドが表示されます。
データタスクステップで
[追加]
アイコンをクリックすると、次のいずれかのビューが表示されます。
  • データタスクステップにタスクが含まれている場合、タスクの編集不可能なビューが開きます。
  • データタスクステップにタスクが含まれていない場合は、タスクを選択できるダイアログボックスが表示されます。
タスクをデータタスクステップに追加すると、テキスト型の対応するタスクフロー一時フィールドが作成されます。データタスクステップにタスクを追加すると、一時フィールドのタイプはタスクの名前になります。詳細については、「一時フィールド」を参照してください。

入力フィールド

タスクをタスクフローに追加すると、
[入力フィールド]
セクションが表示されます。
[最大待機時間(秒)]
フィールドでは、データタスクステップがデータ統合タスクの完了を待機する最大時間を秒単位で設定できます。1秒から604800秒の間の値を指定します。デフォルトは604800秒、つまり7日間です。フィールドに指定された最大時間内にタスクが完了しない場合、タスクは実行を停止し、タスクフローの後続のタスクの実行が開始されます。
指定した値が1未満または604800より大きい場合、最大待機時間は自動的に604800秒に設定されます。
上書きできるパラメータがタスクに含まれている場合は、入力フィールドを追加できます。入力フィールドのプロパティを設定して、
データ統合
ランタイムパラメータを上書きできます。ランタイムパラメータの詳細については、Overriding Runtime Input Parameters in a Data Task Stepを参照してください。
データタスクステップで
PowerCenterタスクまたは
マッピング
タスクを使用する場合は、タスクの入力パラメータと入出力パラメータの値を上書きできます。
データタスクステップでマッピングタスクを使用する場合は、次の上書き操作を実行できます。
  • マッピング
    タスクにSecure Agentマシンで使用可能なパラメータファイルが含まれている場合は、パラメータファイルディレクトリとパラメータファイル名を上書きできます。
  • マッピング
    タスクに、クラウドでホストされているリポジトリで使用可能なパラメータファイルが含まれている場合は、パラメータファイル接続とパラメータファイルオブジェクトを上書きできます。データ統合では、
    マッピング
    タスク用にAmazon S3 V2、Azure Data Lake Store Gen2、およびGoogle Storage V2の接続タイプのみがサポートされています。
  • マッピング
    タスクでデータ形式オプションを使用する場合は、ソースデータのデータ形式とデフォルトの精度値を上書きできます。これらのオプションは、形式ファイルが
    マッピング
    ではなく
    マッピング
    タスクにアップロードされている場合にのみ、入力フィールドで使用できます。デフォルトの精度フィールドに設定された精度値は、データ形式フィールドまたは
    マッピング
    タスクに設定された精度よりも優先されます。デフォルトの精度値は、形式ファイル内のすべてのカラムに適用されます。
  • マッピング
    タスクにルックアップトランスフォーメーションが含まれている場合は、ルックアップオブジェクトとルックアップ条件の値を上書きできます。
パラメータファイルからの文字列またはテキストタイプの入力パラメータの値を上書きすることはできません。ただし、タスクフローからの入力パラメータ値は上書きすることができます。パラメータファイルからの接続パラメータ値は上書きできます。
データタスクステップで
動的マッピング
タスクを使用する場合、
[ジョブフィルタ]
という名前の入力パラメータを追加できます。入力フィールドの名前は編集できません。ただし、タスクフローで実行する
動的マッピング
タスクからグループとジョブを指定することはできます。
グループとジョブを指定するには、
[編集]
をクリックしてから、
<group_name>.<job_name>
という値をコンテンツタイプとともに入力フィールドに入力します。例えば、
動的マッピング
タスクからGroup_1とJob_1を実行する場合は、
[ジョブフィルタ]
入力フィールドに
Group_1.Job_1
という値を入力します。
[ジョブフィルタ]
入力フィールドを追加しない場合、タスクフローではデフォルトで、
動的マッピング
タスクで使用可能なすべてのジョブが指定した順序で実行されます。

出力フィールド

タスクフローに
同期
タスクまたはPowerCenterタスクを追加すると、
[出力フィールド]
セクションが表示されます。
[出力フィールド]
セクションは、タスクの実行時に表示される出力データフィールドの完全な一覧です。
次の図は、表示される出力フィールドを示しています。
この図は、タスクフローの実行時に表示される9つのデータタスク出力フィールドを示します。フィールドには、[実行ID]、[ログID]、[タスクID]、[タスクステータス]、[成功したソース行]、[失敗したソース行]、[成功したターゲット行]、[失敗したターゲット行]、[開始時刻]、[終了時刻]、および[エラーメッセージ]があります。
マッピング
タスクが
詳細クラスタ
で実行される場合は、次のフィールドが表示されます。
この図は、スケールマッピングに基づくマッピングタスクで表示されるデータタスク出力データフィールドを示しています。このフィールドには、[実行ID]、[ログID]、[タスクステータス]、[成功したターゲット行]、[失敗したターゲット行]、[開始時刻]、[終了時間]、[エラーメッセージ]が含まれます。
詳細クラスタ
で実行される
マッピング
タスクの場合、タスクの実行時に、成功したソース行と失敗したソース行は取り込まれません。
データ転送
タスク
または
動的マッピング
タスクを使用すると
、次のフィールドが表示されます。
この図は、タスクフローでデータ転送タスクまたは動的マッピングタスクを使用する場合のデータタスクの出力フィールドを示しています。フィールドは、[実行ID]、[ステータス]、[成功した行]、[失敗した行]、[エラーメッセージ]です。
各出力フィールドの値を表示するには、タスクフローを実行し、
[タスクフローインスタンスの詳細]
ページに移動します。
[タスクフローインスタンスの詳細]
ページの詳細については、
モニタ
のヘルプ
を参照してください。
データ決定または割り当てのステップで出力フィールドを使用できます。
例えば、値式の一時フィールドを作成し、次の式を使用してデータをフィールドに割り当てます。
if( ($temp.DataTask1[1]/output[1]/Failed_Target_Rows < 0 or $temp.DataTask1[1]/output[1]/Task_Status = '1') and ($temp.DataTask2[1]/output[1]/Success_Target_Rows > 0 and $temp.DataTask2[1]/output[1]/Failed_Target_Rows = 0) and $temp.DataTask3[1]/output[1]/Success_Target_Rows > 0) then 'Pass' else 'Fail'
決定ステップで一時フィールドを使用すると、次の条件が満たされた場合、タスクフローは
Pass
パスを受け取ります。
  • データタスク1には、失敗したターゲット行はありません。またはデータタスク1は、正常に実行されています。
  • データタスク2には、少なくとも1つの成功したターゲット行があります。
  • データタスク2では、失敗したターゲット行はゼロです。
  • データタスク3には、少なくとも1つの成功したターゲット行があります。

タイマイベント

タスクにタイマを追加するには、次の
イベント
プロパティを入力します。
タイマイベントを使用して、スケジュールに基づいてアクションを実行します。アクションは、特定の時刻または間隔の後のいずれかになります。
データタスクステップにタイマを追加すると、新しい分岐が表示されます。この分岐にイベントを追加し、特定の
[時間]
または間隔
[以降]
に実行するかどうかを指定します。
次の図では、タイマ分岐のイベント(データ決定ステップ)が、メインデータタスクの5分後に発生します。
メインデータステップが開始されてから5分後に実行されるようにタイマが設定されているデータ決定ステップ。タイマイベントは、データ決定ステップです。
タイマが起動すると、タスクフローは常にタイマ分岐全体を通して実行されます。データタスク1が決定1の前に終了する場合、タイマ分岐は実行されません。
タイマでメインデータタスクを中断する場合は、
[中断]
を選択します。中断タイマを設定すると、メインデータタスクが中断され、タスクフローはタイマ設定に基づいてイベントのみを実行します。
次の図は、メインデータタスクが開始されてから5分後に発生する中断タイマ設定を示しています。
タイマ分岐に基づくイベントの場合、データタスク2が実行され、データタスク1が中断されます。タスクフローはタイマ分岐に従います。つまり、タスクフローはデータタスク2を実行してから終了します。
中断タイマのタイマ分岐の終了ステップを削除すると、タイマ分岐はメイン分岐に再び参加します。
次の図は、終了ステップが削除された中断タイマ分岐を示しています。
タイマイベント(データタスク2)は、5分後に実行され、データタスク1を中断します。タイマ分岐は、メイン分岐に再び参加します。タスクフローは、データタスク2、並列パスステップを実行し、終了します。
中断タイマを使用する場合、メインデータタスクには、このタスクフローインスタンスに対する出力はありません。タスクフローのジョブの詳細ページには、メインデータタスクの出力フィールドが表示されません。
データタスクステップがタイマ、中断、または非中断の前に完了した場合、そのデータタスクステップに対してタイマは起動しません。

エラー処理

[エラー処理]セクションを使用すると、データタスクステップが警告またはエラーを検出したときにタスクフローがどのように動作するかを指定できます。データタスクステップに関連付けられたタスクが失敗した場合、または実行されなかった場合のタスクフローの動作を設定することもできます。
タスクを選択した後に、次のエラー処理のプロパティを入力します。
プロパティ
説明
警告時
データタスクステップで警告が発生したときにタスクフローが受け取るパス。
警告は、データタスクステップが誤った仕方で完了したか、または完了しなかった場合に発生します。例えば、データタスクステップで、テーブルAからテーブルBに25行のうち20行のみをコピーする場合、警告が表示されます。
次のオプションから選択できます。
  • 警告を無視して次のステップに進むには、
    [無視]
    を選択します。
    通知タスクステップが後に続くデータタスクステップに
    [無視]
    を選択してデータタスクが失敗した場合は、受信する電子メール通知にはフォールトの詳細は含まれません。電子メールでフォールトの詳細を確認するには、
    [カスタムエラー処理]
    を選択します。
  • 警告が発生したときにタスクフローを中断状態に移行させるには、
    [タスクフローの中断]
    を選択します。
    [すべてのジョブ]
    [実行中のジョブ]
    、および
    [マイジョブ]
    ページからタスクフローインスタンスを再開できます。
    タスクフローは、中断されたステップから再開します。警告の理由がわかっている場合は、問題を修正してからタスクフローを再開してください。
デフォルト値:
無視
エラー発生時
データタスクステップでエラーが発生したときにタスクフローが受け取るパス。
データタスクステップが失敗するとエラーが発生します。例えば、データタスクがテーブルAをテーブルBにコピーしない場合、エラーが表示されます。
次のオプションから選択できます。
  • [無視]
    を選択してエラーを無視し、次の手順に進みます。
  • エラーが発生したときにタスクフローを中断状態に移行させるには、
    [タスクフローの中断]
    を選択します。
    [すべてのジョブ]
    [実行中のジョブ]
    、および
    [マイジョブ]
    ページからタスクフローインスタンスを再開できます。
    タスクフローは、中断されたステップから再開します。エラーの理由がわかっている場合は、問題を修正してからタスクフローを再開してください。
  • 選択した方法でエラーを処理するには、
    [カスタムエラー処理]
    を選択します。
    [カスタムエラー処理]
    を選択すると、2つの分岐が表示されます。最初の分岐は、エラーが発生しない場合にタスクフローが続くパスです。2番目の分岐は、エラーが発生した場合にタスクフローが続くカスタムパスです。
デフォルト値:
タスクフローの中断
タスクフローを完了時に終了
データタスクステップに関連付けられたタスクが失敗した場合、または実行されなかった場合のタスクフローの動作。
データタスクステップに関連付けられたタスクが失敗した場合、または実行されなかった場合に、完了時に失敗するようにタスクフローを設定できます。タスクが失敗するか実行されなかった場合、タスクフローは後続のステップの実行を続行します。ただし、タスクフローが完了すると、タスクフローのステータスは失敗に設定されます。
[フォールト時に一時停止]
タスクフローの詳細プロパティと
[タスクフローを完了時に終了]
プロパティの両方を設定した場合は、
[フォールト時に一時停止]
プロパティが優先されます。この場合、データタスクステップに関連付けられたタスクが失敗するか実行されない場合、タスクフローは一時停止されます。タスクフローは、データタスクステップの後の後続のステップを実行しません。
次の図は、割り当てステップと別のデータタスクステップがある、
カスタムエラー処理
パスを示しています。
割り当てステップおよび別のデータタスクステップのカスタムエラー処理があるデータタスクステップ。