変換されたデータを追跡する
学習の目的
この単元を完了すると、次のことができるようになります。
- ビルダーから DPE 定義を実行する。
- リベートオーケストレーションフロー 2 を実行する。
- 進行中の DPE 実行を監視する。
- リベートメンバー商品集計オブジェクトの集計レコードを追跡する。
試してみましょう
Rishi は、DPE 定義をテストして、すべてのノードが正しく動作するかどうかを確認するために、DPE ビルダー内のあるオプションに注目しました。Rishi はこの実行に固有の入力変数をいくつか指定することで、[ワークフローサービスを監視] で実行の進捗状況を追跡できます。定義をテストするための作業は次のとおりです。
- データ処理エンジンヘッダーにある [有効化] をクリックします。
- [定義を実行] をクリックします。
- [次へ] をクリックします。
- ページ URL から DPE 定義の ID をコピーして ("dataProcessingEngineId=" の後の 18 文字の英数字)、入力変数項目の [Data Processing Engine Id (データ処理エンジン ID)] に貼り付けます。
- 以下の入力変数が正しく入力されていることを確認してください。
- Program Rebate Type Filter (プログラムリベート種別検索条件)
- Rebate Program Filter (リベートプログラム検索条件)
- Rebate Program Member Filter (リベートプログラムメンバー検索条件)
- Rebate Program Payout Period Filter (リベートプログラム支払期間検索条件)
- [定義を実行] をクリックします。
Rishi はこの実行でのみ使用する入力変数値を指定します。検索条件ノードと数式ノードに他の入力変数を設定している場合は、その入力変数も指定します。定義を実行すると、一括処理ジョブが作成されます。
オーケストレーションフロー
Cindy は、リベートオーケストレーションフロー 2 をコピーして、毎週実行されるようにスケジュールします。このフローでは、[プロセス種別] が [リベート] の DPE 定義を自動的に検索し、支払金額を生成する計算プロセスをトリガーします。[リベート DPE ジョブを実行] は、リベートオーケストレーションフロー 2 内のサブフローです。サブフローでは、DPE 定義を実行して支払計算用のデータを集計し、レコードを生成します。
また、Cindy は入力変数として [AMER パートナー年間リベート] プログラムの [リベートプログラム ID] も指定し、そのリベートプログラムのみを対象としてフローが実行されるようにします。
そこで、次の作業を実行します。
- をクリックし、[設定] を選択します。
- [クイック検索] ボックスに、
フロー
と入力します。 - [プロセスの自動化] の下の [フロー] を選択します。
- [リベートオーケストレーションフロー 2] をクリックします。
- ヘッダーの [別名で保存] をクリックして、次の詳細を指定します。
- フロー表示ラベル:
Rebate Orchestration Flow 2_AMER Rebate Programs
- [詳細を表示] をクリックし、[スケジュールトリガーフロー] として [種別] を選択します。
- フロー表示ラベル:
- [保存] をクリックします。
- コピーされたバージョンが開いたら、フロービルダー内にある [開始] 要素の [スケジュールを設定] をクリックして、次の詳細を指定します。
- 開始日: 現在の日付
- 開始時刻: 現在の時間
- 頻度: 毎週
- [完了] をクリックします。
- [開始] 要素の [オブジェクトを選択] をクリックして、次の詳細を指定します。
- オブジェクト: リベートプログラム
- 条件の要件: [すべての条件に一致 (AND)]
- 項目: リベートプログラム ID
- 演算子: =
- 値: AMER パートナー年間リベートのリベートプログラムの ID
- [完了] をクリックします。
- フロービルダーのヘッダーにある [有効化] をクリックします。
-
[実行] をクリックして [毎週] フローをトリガーします。
Cindy はデータ処理エンジン実行をトリガーして、AMER パートナー年間リベートのリベートプログラム用の値のみが適用されるようにしました。Cindy はデータ処理エンジンの実行を追跡でき、Rishi は書き戻しオブジェクトであるリベートメンバー商品集計で集計を確認できます。
実行を監視する
すべての DPE 一括処理ジョブは、[設定] で監視できます。進行中の DPE 実行を追跡するために、Rishi は次の作業を行います。
- をクリックし、[設定] を選択します。
- [クイック検索] ボックスに
ワークフローサービスを監視
と入力します。 - [ワークフローサービス] の下の [ワークフローサービスを監視] をクリックします。
- 追跡する一括処理ジョブ名をクリックします。Rishi は、[Aggregate by Member_AMER Rebate Program Aggregation (メンバー別集計_AMER リベートプログラム集計)] をクリックします。状況は [進行中] です。
- 一括処理ジョブ実行レコードの [詳細] タブでは、次の主要な詳細情報を確認できます。
- 実行開始時刻
- 実行終了時刻
- 状況
- 失敗したレコード件数
- 一括処理ジョブ実行レコードの [ToDo] タブでは、DPE 定義の各一括処理ジョブの一部の状況を確認できます。データ取得元と書き戻しオブジェクトは、この DPE の一括処理ジョブの一部であり、最終的な実行タスクでもあります。
Cindy と Rishi は、先ほど完了したすばらしい作業の小さなご褒美として、やっとコーヒーを飲んだりして休憩できます。休憩が終わるころには、DPE 実行は正常に完了しているでしょう。
集計を追跡する
4 月下旬、パートナーからはすでに当月分の取引レコードが送信されてきています。Rishi が DPE 定義を実行すると、そのジョブによってある日付までのすべての取引レコードが取得され、適宜集計が行われます。Rayler Parts のパートナーである Summit Resellers の集計データを確認するために、Rishi がどのような作業を行うのかを見てみましょう。
- をクリックし、[リベートメンバー商品集計] を見つけて選択します。
- Rishi はカスタムリストビュー [Rayler Parts Payout Aggregates (Rayler Parts の支払集計)] を選択して、特定のデータを表示します。リストビューでは、表示する項目として [Total Discounted Transaction Amount (割引後トランザクション合計金額)] と [商品カテゴリ] を選択することができます。
- また、支払期間が 4 月の Summit Reseller は 2 行あり、次の情報が表示されています。
- メンバー
- 支払期間
- リベート種別
- Product Category (商品カテゴリ)
- Total Transaction Amount (トランザクション合計金額)
- Total Discounted Transaction Amount (割引後トランザクション合計金額)
素晴らしい! Rishi は取引先マネージャーに依頼された要件を満たすことができたことを伝えます。これで、各集計レコードに割引後の取引合計金額が表示されるようになりました。また、データはメンバーごと、支払期間ごと、リベート種別ごとだけでなく、商品カテゴリごとにもグループ化されています。
データ処理エンジンは強力なデータ変換ツールであり、リベート管理とシームレスに連動します。
最後に
この知らせは瞬く間に広まり、取引先マネージャーはすでにリベート支払集計に対応する新しいユースケースの準備を開始しています。Rishi は、リベート管理の DPE 定義を使用すれば、可能性は無限大だということを理解できました。さっそく、データ処理エンジンの他のカスタマイズもいろいろ試してみたいと思っています。