ワークフローを作成し、開始イベントと終了イベントを追加します。

データセットに重複レコードがないかどうかを調べる

Mapping_1

というマッピングを作成します。このマッピングに含まれる例外トランスフォーメーションで、品質が正常なレコードを

Good_Records

という名前のデータベーステーブルに書き込み、例外を

Exceptions

という名前のテーブルに書き込みます。

ワークフローにマッピングタスクを追加し、

Mapping_1

を実行するようにタスクを設定します。

ワークフローにヒューマンタスクを追加し、

Exceptions

テーブルのデータをユーザーに割り当てるようにタスクを設定します。

Mapping_2

というマッピングを作成し、

Exceptions

テーブルを読み取って、ヒューマンタスクでステータスが「承認済み」に更新されたレコードを

Good_Records

テーブルに書き込むように設定します。

ワークフローにマッピングタスクをもう1つ追加し、そのマッピングタスクに

Mapping_2

を追加します。

選択したユーザーに電子メールメッセージを送信するように通知タスクを設定します。その電子メールメッセージで、マッピングタスクが完了したことを通知します。

ワークフローでイベントとタスクを接続します。