はじめに

OCI Data Integrationは、他の多くのOCIサービスと同様にOCI Eventsサービス、Notificationサービスを使用してイベントや通知を利用することができます。タスク実行の開始、完了で通知させるよう試してみました。前提として必要なポリシーは設定済みとします。

テスト用のタスクを作成

テスト用にObject StorageからCSVファイルをAutonmous Databaseにロードするデータ・ロードタスクを作成しました。

アプリケーションに公開をして実行できることを確認しておきます。

Notificationサービスでトピックとサブスクリプションを作成

OCI Eventsの結果を通知させるためにはOCI Notificationサービスでトピックとサブスクリプションを作成する必要があります。作成手順についてはOCIチュートリアルのOCI DevOpsの事前準備が丁寧でしたので、そちらを参考にしていただければと思います。

OCI Eventsサービスでルールを作成

OCIコンソールで監視および管理からイベント・サービスをクリックし、ルールを作成します。
表示名をOCIDI_task_ruleとし、以下の条件を設定しました。

条件：イベント・タイプ
サービス名：Data Integration
イベント・タイプ：Execute Task-Begin 、 Execute Task-End

アクションには、アクション・タイプを通知とし、コンパートメントとトピックには、事前にOCI Notificationサービスで作成したトピックとそのコンパートメントを指定します。

タスクを実行して通知を確認

OCI Data Integrationでデータ・ローダータスクを実行します。

成功しました。Notificationのサブスクリプションで指定したメールアドレス宛には、開始イベント（cratetaskrun.begin)と完了イベント(createtaskrun.end）でメールが届いていることが確認できました。

開始イベントの通知はこちらのような内容でした。

完了イベントの通知はこちらのような内容でした。

エラーになったタスクだけ通知をさせてみる

完了通知の内容にはさまざまな情報が記載されています。そのなかにtaskStatusという属性があります。この属性をEventsルールに指定して、エラーが発生したときのみ通知ができるか試してみます。

作成したルールを編集して、条件を追加します。属性名はプルダウンメニューから選択、属性値は手入力します。

条件：属性
属性名：taskStatus
属性値：ERROR

条件を追加後、保存します。TaskStatusの属性は開始イベントにはないので、エラーになれば、完了イベントだけが通知されるはずです。

それではデータ・ローダータスクを実行します。ターゲットの表には主キーがあるため、同じファイルのロードでは一意制約違反（ORA-00001）で失敗するというシナリオです。

エラーになりました。ログには想定通り、ORA-00001が出力されています。

通知の方も想定通り、完了イベントcreatetaskrun.endのみ届いています。（2行目は前回の完了イベントです）

内容を見ると、taskStatusがERRORになっていました。

おわりに

OCI Data Integrationのタスク実行の通知をOCI EventsサービスとOCI Notificationサービスと連携して行ってみました。設定や条件、属性のフィルタなどとても簡単に行えることがわかりました。
タスク実行の監視や、タスク実行結果を元にアクションを行うといったケースなどでご利用いただけるのではないかと思います。

参考資料

ドキュメント：OCI Data Integrationのイベント