1. Oracle Stream Analyticsビジュアライザの使用
  2. イベント処理ネットワーク

4 イベント処理ネットワーク

この章では、Oracle Stream Analytics Visualizerを使用してデプロイ済のOracle Stream Analyticsアプリケーションのイベント処理ネットワーク(EPN)を管理する方法について説明します。EPNをグラフィックで表示する方法、EPNステージ構成の表示および編集方法、イベントのデバッグ、トレースおよびインジェクトのためのイベント・フローの記録および再生方法についても説明します。さらに、チャネルやEPNにおけるステージやパスのスループットや待機時間の監視方法についても説明します。

注意:

あるアプリケーション(application-1)が通知するチャネルを別のアプリケーション(application-2)がサブスクライブして外部ステージとして使用する場合、その通知されるチャネルの詳細をapplication-2から表示できません。このチャネルの詳細を表示するには、application-1からそれを行う必要があります。

この章の内容は次のとおりです。

詳細は、「EPNの管理」を参照してください。

4.1 アプリケーションのEPNの表示

Oracle Stream Analytics Visualizerを使用すると、デプロイされたアプリケーションのEPNを表示できます。

アプリケーションのEPNの表示

  1. 左ペインで、アプリケーションがデプロイされているOracle Stream Analyticsサーバー・インスタンスの「アプリケーション」ノードに移動し、展開します。

  2. 「appname」を選択します。ここで、「appname」は、表示対象のEPNが含まれるアプリケーション名です。

  3. 右ペインで、「イベント処理ネットワーク」タブをクリックします。

    図4-1で示すように、「イベント処理ネットワーク」パネルが表示されます。

    図4-1 「イベント処理ネットワーク」パネル

    図4-1の説明が続きます
    「図4-1「イベント処理ネットワーク」パネル」の説明

    ステージ名がステージの上に黒文字で表示されます。たとえば、FindCrossRatesという名前のOracle CQLプロセッサがあり、そのインバウンド・チャネルの名前がFxQuoteStreamであるとします。

    所定のチャネル上で送信されるイベント・タイプの名前が、接続線の下に青字のテキストで表示されます。たとえば、FxQuoteStream上で送信されるイベント・タイプはCrossRateEventです。

  4. 画面外のEPN領域へナビゲートするには、ミニチュアのEPNビューの中をクリックしてドラッグします。

  5. EPNのレイアウトを変更するには、「レイアウト」メニューからレイアウト・オプションを選択します。

    • organic

    • tree

    • hierarchic (デフォルト)

    • balloon

    • orthogonal

  6. EPNがブラウザ・ウィンドウ内に収まるように変更するには:

    1. ズーム・レベルを上げるには、「ズーム」スライダ上でクリックして右にドラッグします。ズーム・レベルを下げるには、左にドラッグします。

    2. 「内容に合せる」ボタンをクリックすると、自動的にズーム・レベルが調整され、すべてのEPNがブラウザ・ウィンドウで表示されるようになります。「実際のサイズ」ボタンをクリックすると、ズーム・レベルがゼロにリセットされます。

    3. 「ズーム・アウト」(+)ボタンまたは「ズーム・イン」(-)ボタンをクリックします。

4.2 ステージの構成の表示および編集

Oracle Stream Analytics Visualizerを使用すると、任意のステージの構成を表示し、一部のステージの構成を変更できます。

注意:

ルールおよびOracle高可用性アダプタへの変更は、同一グループ内の他のサーバーへ伝播されます。つまり、すべてのルールおよびOracle高可用性アダプタの構成は、自動的に同期されることになります。他の構成の変更は同期されません。たとえば、マルチサーバー・ドメイン内の1つのサーバーで記録/再生またはJMSアダプタの構成を変更する場合、これらの変更は同一グループ内の他のサーバーには同期されません。詳細は、「マルチサーバー・ドメイン」を参照してください。

4.2.1 ステージの構成を表示/編集する方法

Oracle Stream Analytics Visualizerを使用して、ステージの構成を表示/変更できます。

ステージの構成を表示および編集するには、次の手順を実行します。

  1. 左ペインで、アプリケーションがデプロイされているOracle Stream Analyticsサーバー・インスタンスの「アプリケーション」ノードに移動し、展開します。

  2. 「appname」を選択します。ここで、「appname」は、使用するアプリケーション名です。

  3. 表示および構成するステージを選択します。

    1. EPNダイアグラムを使用するには:

      • 「イベント処理ネットワーク」タブをクリックします。

      • 表示するステージをダブルクリックするか、ステージを右クリックしてパネルを開くを選択します。

    2. ドメイン・ツリーを使用するには:

      • 「appname」→「ステージ」ノードを展開します。ここで、「appname」は、表示するアプリケーション名です。

      • 表示するステージをクリックします。

      • 右ペインで、「一般」タブをクリックします。

    ステージの構成が表示されます。

    たとえば、図4-2はチャネルの「一般」タブを示しています。

    図4-2 チャネル・ステージの「一般」タブ:「編集」をクリックする前

    図4-2の説明が続きます
    「図4-2 チャネル・ステージの「一般」タブ:「編集」をクリックする前」の説明

    注意:

    一部Oracle Stream Analytics Visualizerによって構成が更新されないステージもあります。構成が更新できる場合は、「編集」ボタンが表示されます。

    可能がある各ステージ構成プロパティの説明は、次を参照してください。

  4. 表示されている場合は、「編集」ボタンをクリックします。

    図4-3で示すように、変更可能な属性が編集できるようになります。

    図4-3 チャネル・ステージの「一般」タブ:「編集」をクリックした後

    図4-3の説明が続きます
    「図4-3 チャネル・ステージの「一般」タブ:「編集」をクリックした後」の説明

  5. 編集可能なフィールドの値を入力します。

    たとえば、図4-3の「最大サイズ」および「最大スレッド数」フィールドの値です。

  6. 変更を確定するには、「保存」をクリックします。

  7. 構成を変更しないままにする場合は、「取消し」をクリックします。

4.2.1.1 チャネル・プロパティ

図4-4は、チャネル・ステージの「一般」タブを示します。

図4-4 チャネル・ステージの「一般」タブ

図4-4の説明が続きます
「図4-4 チャネル・ステージの「一般」タブ」の説明

「編集」をクリックした後、グレー表示ではない属性を変更できます。表4-1は、このステージの「一般」タブにあるすべての属性を説明しています。

表4-1 「一般」タブのプロパティ:「チャネル」

属性 説明

チャネル・タイプ

ストリームまたはリレーション。

最大サイズ

チャネルの最大サイズを指定します。サイズがゼロのチャネルは、同期的にイベントを受け渡します。サイズがゼロでないチャネルはイベントを非同期的に処理し、リクエストされたサイズに従ってイベントをバッファリングします。デフォルト値は0 (ゼロ)です。

最大スレッド数

このチャネルのイベントを処理するために使用されるスレッドの最大数を指定します。

「最大スレッド数」は、再デプロイせずに0から正の整数(つまり、パス・スルーから複数のスレッド)まで変更できます。ただし、「最大スレッド数」を正の整数から0に変更する場合(つまり、複数のスレッドからパス・スルーに変更する場合)、アプリケーションを再デプロイする必要があります。

「最大サイズ」属性が0の場合は、「最大スレッド数」の値の設定には影響がありません。

この属性のデフォルト値は0です。

イベント・タイプ名

このチャネルが送信するイベント・タイプ名。

タイムスタンプ・タイプ

この要素を使用すると、チャネルがアプリケーション・タイムスタンプかどうか、つまり、アプリケーションが任意のタイム・ドメインを使用してタイムスタンプを各イベントへ割り当てる処理ができるかどうかを指定します。有効な値は以下のとおりです。

  • SYSTEM-TIME (デフォルト)

  • APPLICATION-TIME

タイムスタンプ・プロパティ

この要素は、イベント処理のためにアプリケーション・タイムスタンプとして使用する式の指定に使用します。有効な値は、Oracle CQL算術式です。

自動ハートビート

システムがタイムスタンプを付けたリレーションまたはストリームでは、時間は、リレーションまたはストリームのソース上のデータの受信に依存します。Oracle Stream Analyticsは、このナノ秒を超えてアクティビティがない場合(ストリームまたは関係のソースにデータが到着しない場合)、システムがタイムスタンプを付けた関係またはストリーム上でハートビートを生成します。リレーションまたはストリームのいずれかがその指定されたソースから移入されるか、Oracle Stream Analyticsが自動ハートビートのナノ秒数ごとにハートビートを生成します。

注意: この属性は、ストリーム以外のソースがチャネルに接続されているときのみ適用できます。

全体順序

パブリッシュされたアプリケーション時間が常に前回使用された値よりも大きくなる場合に指定します。

有効な値はtrueまたはfalseです。デフォルト: false。

詳細は、次を参照してください。

4.2.1.2 チャネル・プロパティ: アウトバウンド・チャネル

図4-5は、アップストリームOracle CQLプロセッサを使用するアウトバウンド・チャネル・ステージの「一般」タブを示します。「チャネル・パラメータ」アコーディオン・タブが選択されています。

図4-5 「一般」タブのアウトバウンド・チャネル・パラメータ

図4-5の説明が続きます
「図4-5「一般」タブのアウトバウンド・チャネル・パラメータ」の説明

「編集」をクリックした後、グレー表示ではない属性を変更できます。表4-2は、このステージの「一般」タブにあるすべての属性を説明しています。

表4-2 「一般」タブのプロパティ:アウトバウンド・チャネル

属性 説明

チャネル・タイプ

ストリームまたはリレーション。

最大サイズ

チャネルの最大サイズを指定します。サイズがゼロのチャネルは、同期的にイベントを受け渡します。サイズがゼロでないチャネルはイベントを非同期的に処理し、リクエストされたサイズに従ってイベントをバッファリングします。デフォルト値は0 (ゼロ)です。

最大スレッド数

このチャネルのイベントを処理するために使用されるスレッドの最大数を指定します。

「最大スレッド数」は、再デプロイせずに0から正の整数(つまり、パス・スルーから複数のスレッド)まで変更できます。ただし、「最大スレッド数」を正の整数から0に変更する場合(つまり、複数のスレッドからパス・スルーに変更する場合)、アプリケーションを再デプロイする必要があります。

「最大サイズ」属性が0の場合は、「最大スレッド数」の値の設定には影響がありません。

この属性のデフォルト値は0です。

イベント・タイプ名

このチャネルが送信するイベント・タイプ名。

詳細は、次を参照してください。

4.2.1.3 チャネル・プロパティ: 問合せセレクタを使用したアウトバウンド・チャネル

図4-6は、アップストリームOracle CQLプロセッサを使用するチャネル・ステージの「一般」タブを示します。「セレクタ」アコーディオン・タブが選択されています。

図4-6 アウトバウンド・チャネル・ステージの「一般」タブの「セレクタ」

図4-6の説明が続きます
「図4-6 アウトバウンド・チャネル・ステージの「一般」タブの「セレクタ」」の説明

「セレクタ」タブは、アップストリーム・ノードがOracle CQLプロセッサの場合のみ適用できます。

「編集」をクリックした後、「セレクタ」タブを使用すると、どのアップストリームOracle CQLプロセッサの問合せが結果をチャネルへ出力されるかを指定できます。

  1. 「プロセッサ」プルダウン・メニューから、アップストリームOracle CQLプロセッサを選択します。

    選択プロセッサに関連付けられた使用可能なOracle CQLルールは、プルダウン・メニューの下にリストされます。

  2. 左向き/右向きの矢印ボタンを使用すると、1つ以上のルールを「選択された問合せ」リストへ移動できます。

    「選択された問合せ」リストにあるルールのみがイベントをチャネルへ出力します。

注意:

問合せ名をチャネル・セレクタに追加する前に、アップストリームOracle CQLプロセッサに問合せを追加する必要があります。詳細は、「問合せウィザードによるルールの作成」を参照してください。

詳細は、「チャネル・プロパティ: アウトバウンド・チャネル」を参照してください。

4.2.1.4 ストリーム・プロパティ

図4-7は、ストリーム・ステージの「一般」タブを示します。

図4-7 チャネル・ステージの「一般」タブ

図4-7の説明が続きます
「図4-7 チャネル・ステージの「一般」タブ」の説明

「編集」をクリックした後、グレー表示ではない属性を変更できます。表4-3は、このステージの「一般」タブにあるすべての属性を説明しています。

表4-3 「一般」タブのプロパティ: ストリーム

属性 説明

最大サイズ

ストリームの最大サイズを指定します。サイズがゼロのストリームは、同期的にイベントを受け渡します。サイズがゼロでないストリームはイベントを非同期的に処理し、リクエストされたサイズに従ってイベントをバッファリングします。デフォルト値は1024です。

最大スレッド数

このストリームのイベントを処理するために使用されるスレッドの最大数を指定します。

「最大スレッド数」は、再デプロイせずに0から正の整数(つまり、パス・スルーから複数のスレッド)まで変更できます。ただし、「最大スレッド数」を正の整数から0に変更する場合(つまり、複数のスレッドからパス・スルーに変更する場合)、アプリケーションを再デプロイする必要があります。

「最大サイズ」属性が0の場合は、「最大スレッド数」の値の設定には影響がありません。

この属性のデフォルト値は1です。

4.2.1.5 Oracle CQLプロセッサのプロパティ

図4-8は、Oracle CQLプロセッサ・ステージの「一般」タブを示します。

図4-8 Oracle CQLプロセッサ・ステージの「一般」タブ

図4-8の説明が続きます
「図4-8 Oracle CQLプロセッサ・ステージの「一般」タブ」の説明

このステージ・タイプには編集可能なプロパティがありません。

4.2.1.6 アダプタのプロパティ

図4-9は、アダプタ・ステージの「一般」タブを示します。

図4-9 アダプタ・ステージの「一般」タブ

図4-9の説明が続きます
「図4-9 アダプタ・ステージの「一般」タブ」の説明

このステージ・タイプには編集可能なプロパティがありません。

4.2.1.7 JMSアダプタのプロパティ

図4-10は、JMSアダプタの「一般」タブを示します。

図4-10 JMSアダプタ・ステージの「一般」タブ

図4-10の説明が続きます
「図4-10 JMSアダプタ・ステージの「一般」タブ」の説明

このステージ・タイプには編集可能なプロパティがありません。

4.2.1.8 高可用性入力アダプタ・プロパティ

図4-11は、Oracle Stream Analytics高可用性入力アダプタの「一般」タブを示します。

図4-11 Oracle Stream Analytics高可用性入力アダプタ・ステージの「一般」タブ

図4-11の説明が続きます
「図4-11 Oracle Stream Analytics高可用性入力アダプタ・ステージの「一般」タブ」の説明

このステージ・タイプには編集可能なプロパティがありません。

4.2.1.9 高可用性バッファリング出力アダプタ・プロパティ

図4-12は、Oracle Stream Analytics高可用性バッファリング出力アダプタの「一般」タブを示します。

図4-12 Oracle Stream Analytics高可用性バッファリング出力アダプタ・ステージの「一般」タブ

図4-12の説明が続きます
「図4-12 Oracle Stream Analytics高可用性バッファリング出力アダプタ・ステージの「一般」タブ」の説明

このステージ・タイプには編集可能なプロパティがありません。

4.2.1.10 高可用性ブロードキャスト出力アダプタ・プロパティ

図4-13は、Oracle Stream Analytics高可用性ブロードキャスト出力アダプタの「一般」タブを示します。

図4-13 高可用性ブロードキャスト出力アダプタ・ステージの「一般」タブ

図4-13の説明が続きます
「図4-13 高可用性ブロードキャスト出力アダプタ・ステージの「一般」タブ」の説明

このステージ・タイプには編集可能なプロパティがありません。

4.2.1.11 高可用性相関出力アダプタ・プロパティ

図4-14は、Oracle Stream Analytics高可用性相関出力アダプタの「一般」タブを示します。

図4-14 Oracle Stream Analytics高可用性相関出力アダプタ・ステージの「一般」タブ

図4-14の説明が続きます
「図4-14 Oracle Stream Analytics高可用性相関出力アダプタ・ステージの「一般」タブ」の説明

このステージ・タイプには編集可能なプロパティがありません。

4.2.1.12 イベントBeanプロパティ

図4-15は、イベントBeanステージの「一般」タブを示します。

図4-15 イベントBeanステージの「一般」タブ

図4-15の説明が続きます
「図4-15 イベントBeanステージの「一般」タブ」の説明

このステージ・タイプには編集可能なプロパティがありません。

4.2.1.13 POJOのプロパティ

図4-16は、Plain Old Java Object (POJO)ステージの「一般」タブを示します。

図4-16 POJOステージの「一般」タブ

図4-16の説明が続きます
「図4-16 POJOステージの「一般」タブ」の説明

このステージ・タイプには編集可能なプロパティがありません。

4.2.1.14 キャッシュ・プロパティ: Oracle Coherenceキャッシュ

図4-17は、Oracle Coherenceキャッシュ・ステージのプロパティを示します。

図4-17 Oracle Coherenceキャッシュ・ステージのプロパティ

図4-17の説明が続きます
「図4-17 Oracle Coherenceキャッシュ・ステージのプロパティ」の説明

このステージ・タイプには編集可能なプロパティがありません。

詳細は、「マルチサーバー・ドメイン」を参照してください。

4.2.1.15 キャッシュ・プロパティ: Oracle Stream Analyticsローカル・キャッシュ

図4-18は、Oracle Stream Analyticsローカル・キャッシュ・ステージのプロパティを示します。

図4-18 Oracle Stream Analyticsローカル・キャッシュ・ステージのプロパティ

図4-18の説明が続きます
「図4-18 Oracle Stream Analyticsローカル・キャッシュ・ステージのプロパティ」の説明

「編集」をクリックした後、グレー表示ではない属性を変更できます。表4-4は、このステージの「一般」タブにあるすべての属性を説明しています。

表4-4 プロパティ: Oracle Stream Analyticsローカル・キャッシュ

属性 説明

最大サイズ

削除またはページングが発生した後のメモリー内のキャッシュ要素数を定義するために、max-size要素を指定します。現状では最大キャッシュサイズは2^31-1エントリです。この要素は動的に変更されます。

アイドル時間

キャッシュ・エントリが能動的にキャッシュから削除される前に、キャッシュ・エントリがアクセスされない時間をミリ秒数で指定します。デフォルトでは、idle-timeは設定されていません。この要素は動的に変更されます。

書込みポリシー

Oracle Stream Analyticsサーバーが情報をキャッシュへ書き込む方法を指定します。有効な値は以下のとおりです。

  • WriteNone:キャッシュ・ストアへの書込みを指定しません。これはデフォルトの書込みポリシーです。この要素は動的に変更できます。

  • WriteThrough:キャッシュ・ストアへの同期的な書込みを指定します。エントリが作成または更新されると、書込みが発生します。この要素は動的に変更されます。

  • WriteBehind:キャッシュ・ストアへの非同期的な書込みを指定します。キャッシュ・ストアは、キャッシュ・エントリの作成または更新の後で各スレッドから起動されます。この要素は動的に変更されます。

削除ポリシー

この要素を使用すると、「最大サイズ」の受信時にキャッシュが使用する削除ポリシーを定義できます。

有効な値は以下のとおりです。

  • FIFO: 先入れ先出し。

  • LRU: 最も長い期間使用されていない

  • LFU: 最も使用頻度が低い(デフォルト)

  • NRU: 最近使用されていない

存続時間

エントリがキャッシュされる時間の最大数をミリ秒で指定します。デフォルト値は0です(無限)。

4.3 EPNにおけるイベントの記録および再生

Oracle Stream Analyticsのイベント・リポジトリ機能を使用すると、イベント処理ネットワーク(EPN)の中を流れるイベントを記録、格納できるため、後からイベントを再生できます。プロセッサやストリームなどのステージごとに、イベントの記録と再生を構成します。また、イベント・ソースからのイベントのみを記録でき、再生はイベント・シンクでのみ可能です(イベントはイベント・シンク・ステージの着信側に再生されます)。

Oracle Stream Analytics Visualizerを使用して制御できる記録および再生の構成オプションは、イベント・タイプ、時間、および速度のみです。

また、「EPNにおけるイベントのトレースおよびインジェクト」で説明されているように、イベントをトレースおよびインジェクトできます。

この項の内容は、次のとおりです。

4.3.1 イベントを記録する方法

Oracle Stream Analytics Visualizerを使用すると、選択したステージのイベントを記録できます。後で、これらのイベントを再生できます(「イベントの再生」を参照してください)。

イベントを記録するには:

  1. 左ペインで、アプリケーションがデプロイされているOracle Stream Analyticsサーバー・インスタンスの「アプリケーション」ノードに移動し、展開します。

  2. 「appname」を選択します。ここで、「appname」は、イベントの記録および再生に使用するアプリケーション名です。

  3. 右ペインで、「イベント処理ネットワーク」タブをクリックします。

    図4-19で示すように、「イベント処理ネットワーク」パネルが表示されます。

    図4-19 「イベント処理ネットワーク」パネル

    図4-19の説明が続きます
    「図4-19「イベント処理ネットワーク」パネル」の説明

  4. イベントを記録する対象のステージを選択します。

    1. EPNダイアグラムを使用するには:

      • イベントを記録する対象のステージを右クリックし、イベントの記録を選択します。

    2. ドメイン・ツリーを使用するには:

      • 「appname」→「ステージ」ノードを展開します。ここで、「appname」は、イベントの記録および再生に使用するアプリケーション名です。

      • イベントを記録する対象のステージをクリックします。

      • 右ペインで、「記録」タブをクリックします。

    図4-20で示すように、「記録」パネルが表示されます。

    図4-20 「記録」タブ

    図4-20の説明が続きます
    「図4-20「記録」タブ」の説明

    特定のステージのOracle Stream Analytics Visualizerにおける「記録」タブは、次のセクションに分割されています。

    • 「記録の現在のステータス」: 記録の現在のステータスを表示します。システムが記録セッションを開始したとき、このフィールドには点滅する記録メッセージが表示され、記録セッションが終了すると空白になります。このセッションは読取り専用です。

    • 「記録パラメータ」: データベース・スキーマの名前(データセット名)およびプロバイダ情報を指定します。イベント・リポジトリのプロバイダを事前に構成する必要があります。

      詳細は、次を参照してください。

    • イベント・タイプ・リスト:「イベント・タイプ・リスト」ペインが含まれ、これには、Oracle Stream Analyticsアプリケーションの選択したステージに関連付けられるイベント・タイプのリストが表示されます。記録するイベント・タイプを1つ以上選択します。

    • 「記録スケジュール・エントリ」: この表のエントリは、記録の開始時間および終了時間を表示します。開始時間および終了時間のエントリはオプションのフィールドです。記録をすぐに開始するには、パネルの下部にある「開始」ボタンをクリックします。

    • 「記録スケジュールの変更」: カレンダおよびクロック・コントロールを使用して、記録の開始時間と終了時間の指定や変更ができます。

  5. 行いたいことを決定します。

    1. 新規記録エントリを追加するには、「追加」をクリックします。

    2. 既存の記録を変更するには、「編集」をクリックします。

    3. 既存のスケジュール・エントリを削除するには、次の操作を行います。

      「記録スケジュール・エントリ」表でエントリを選択し、「編集」をクリックします。

      「記録スケジュールの変更」で、「スケジュールのクリア」ボタンをクリックします。

      「保存」をクリックします。

  6. 次のとおりに「記録パラメータ」を構成します。

    • 「データセット名」: simpleEventSourceアダプタ・アプリケーション構成ファイル/Oracle/Middleware/my_oep/oep/examples/ domains/recplay_domain/defaultserver/applications/ recplay/config.xmlからのrecord-parameters子要素のdataset-name要素の値。 

      <adapter>
    <name>simpleEventSource</name>
    <record-parameters>
        <dataset-name>recplay_sample</dataset-name>
        <event-type-list>
            <event-type>SimpleEvent</event-type>
        </event-type-list>
        <provider-name>test-rdbms-provider</provider-name>
        <batch-size>1</batch-size>
        <batch-time-out>10</batch-time-out>
    </record-parameters>
</adapter>

    • プロバイダ名: data-source子要素に対応するrdbms-event-store-provider子要素のnameの値。

      デフォルトのBerkeleyデータベース・プロバイダを使用するときは、default providerを選択します。 

      <data-source>
    <name>derby1</name>
    <connection-pool-params>
        <initial-capacity>15</initial-capacity>
        <max-capacity>50</max-capacity>
    </connection-pool-params>
    <driver-params>
        <url>jdbc:derby:dbtest1;create=true</url>
        <driver-name>org.apache.derby.jdbc.EmbeddedDriver</driver-name>
    </driver-params>
</data-source>
<rdbms-event-store-provider>
    <name>test-rdbms-provider</name>
    <data-source-name>derby1</data-source-name>
</rdbms-event-store-provider>

      詳細は、「データ・ソースの構成」を参照してください。

  7. 次のとおりに「イベント・タイプ・リスト」を構成します。

    左向き/右向きの矢印ボタンを使用して、「使用可能なイベント・リスト」から記録されたイベント・リストへ記録対象イベントを移動します。

    詳細は、「イベント・タイプ・リポジトリ」を参照してください。

  8. 記録の開始時間および終了時間を決定します。

    1. 記録の開始時間および終了時間をスケジュールする場合は、次の手順を実行します。

      • カレンダおよびクロック・コントロールをクリックして、開始時間および終了時間を追加します。

      • 「保存」をクリックします。

        図4-21で示すように、「アラート」ダイアログが表示されます。

        図4-21 記録スケジュールの確認ダイアログ

        図4-21の説明が続きます
        「図4-21 記録スケジュールの確認ダイアログ」の説明

      • 「OK」をクリックします。

    2. イベントをすぐに記録する場合は、次の手順を実行します。

    Oracle Stream Analytics Visualizerは、特定のステージが現在イベントを記録中または再生中かどうかのトラック情報を保持し、この情報に基づいて、「開始」および「終了」ボタンが状況に応じて有効化/無効化されます。

    Oracle Stream Analytics Visualizerを使用して記録を開始するとき、Oracle Stream Analyticsは、記録エントリからイベント・タイプ情報を使用し、すぐに記録を開始し、事前にスケジュールされた時間がある場合でも、変更はされません。「終了」ボタンを使用すると、セッションの記録をすぐに終了できます。

  9. 記録を終了する時間を決定します。

    1. 終了時間をスケジュールした場合、イベントの記録はその時間に終了します。

    2. イベントの記録をすぐに終了する場合は、「停止」をクリックします。

4.3.2 イベントの再生

Oracle Stream Analytics Visualizerを使用すると、選択したステージの以前に記録したイベントを再生できます。

イベントの再生

  1. 左ペインで、アプリケーションがデプロイされているOracle Stream Analyticsサーバー・インスタンスの「アプリケーション」ノードに移動し、展開します。

  2. 「appname」を選択します。ここで、「appname」は、イベントの記録および再生に使用するアプリケーション名です。

  3. 右ペインで、「イベント処理ネットワーク」タブをクリックします。

    図4-23で示すように、「イベント処理ネットワーク」パネルが表示されます。

    図4-23 「イベント処理ネットワーク」パネル

    図4-23の説明が続きます
    「図4-23「イベント処理ネットワーク」パネル」の説明

  4. イベントを再生する対象のステージを選択します。

    1. EPNダイアグラムを使用するには:

      • イベントを再生する対象のステージを右クリックし、イベントの再生を選択します。

    2. ドメイン・ツリーを使用するには:

      • 「appname」→「ステージ」ノードを展開します。ここで、「appname」は、イベントの記録および再生に使用するアプリケーション名です。

      • イベントを再生する対象のステージをクリックします。

      • 右ペインで、「再生」タブをクリックします。

    図4-24で示すように、「記録」パネルが表示されます。

    図4-24 「再生」タブ

    図4-24の説明が続きます
    「図4-24「再生」タブ」の説明

    特定のステージのOracle Stream Analytics Visualizerにおける「再生」タブは、次のセクションに分割されています。

    • 「再生の現在のステータス」: 再生の現在のステータスを表示します。システムがセッションの再生を開始したとき、このフィールドには点滅する再生メッセージが表示され、再生セッションが終了すると空白になります。このセッションは読取り専用です。

    • 「再生パラメータ」: データベース・スキーマの名前(データセット名)およびプロバイダ情報を指定します。イベント・リポジトリのプロバイダを事前に構成する必要があります。

      詳細は、永続イベント・ストアを参照してください。

    • イベント・タイプ・リスト:「イベント・タイプ・リスト」ペインが含まれ、これには、Oracle Stream Analyticsアプリケーションの選択したステージに関連付けられるイベント・タイプのリストが表示されます。再生するイベント・タイプを1つ以上選択します。

    • 「再生フィルタ・エントリ」: イベント・タイプ・リポジトリのイベント・タイプの再生を実行するために、クロックおよび時間コントロールを使用してフィルタのセットを指定します。指定した開始時間および終了時間の間に記録されたイベントのみが再生されます。

    • 「再生スケジュール・エントリ」: この表のエントリは、再生の開始時間および終了時間を表示します。開始時間および終了時間のエントリはオプションのフィールドです。再生をすぐに開始するには、パネルの下部にある「開始」ボタンをクリックします。

    • 「再生フィルタ・パラメータの変更」: 選択した再生フィルタ・エントリのプロパティの一部を変更できるようにします。

    • 「再生スケジュール・パラメータの変更」: 選択した再生スケジュール・エントリのプロパティの一部を変更できるようにします。カレンダおよびクロック・コントロールを使用すると、イベントを再生する際の既存の開始時間および終了時間を指定または変更できます。

  5. 次のとおりに「再生パラメータ」を構成します。

    • 「データセット名」: SimpleEventSourceアダプタ・アプリケーション構成ファイル/Oracle/Middleware/my_oep/oep/examples/ domains/recplay_domain/defaultserver/applications/ recplay/config.xmlからのrecord-parameters子要素のdataset-name要素の値。 

      <stream>
    <name>eventStream</name>
    <playback-parameters>
        <dataset-name>recplay_sample</dataset-name>
        <event-type-list>
            <event-type>SimpleEvent</event-type>
        </event-type-list>
        <provider-name>test-rdbms-provider</provider-name>
    </playback-parameters>
    <max-size>10000</max-size>
    <max-threads>2</max-threads>
</stream>

    • プロバイダ名: data-source子要素のnameに対応するrdbms-event-store-provider子要素のnameの値。

      デフォルトのBerkeleyデータベース・プロバイダを使用するときは、default providerを選択します。 

      <data-source>
    <name>derby1</name>
    <connection-pool-params>
        <initial-capacity>15</initial-capacity>
        <max-capacity>50</max-capacity>
    </connection-pool-params>
    <driver-params>
        <url>jdbc:derby:dbtest1;create=true</url>
        <driver-name>org.apache.derby.jdbc.EmbeddedDriver</driver-name>
    </driver-params>
</data-source>
<rdbms-event-store-provider>
    <name>test-rdbms-provider</name>
    <data-source-name>derby1</data-source-name>
</rdbms-event-store-provider>

      詳細は、「データ・ソースの構成」を参照してください。

  6. 次のとおりに「イベント・タイプ・リスト」を構成します。

    左向き/右向きの矢印ボタンを使用して、「使用可能なイベント・リスト」から再生イベント・リストへ再生対象イベントを移動します。

    詳細は、「イベント・タイプ・リポジトリ」を参照してください。

  7. 行いたいことを決定します。

    1. 新規再生エントリを追加するには、「追加」をクリックします。

    2. 既存の再生を変更するには、「編集」をクリックします。

    3. 既存の再生フィルタを削除するには、「再生フィルタ・パラメータの変更」で「編集」→「フィルタのクリア」→「保存」の順にクリックします。

    4. 既存の再生スケジュールを削除するには、「再生スケジュール・パラメータの変更」で「編集」→「スケジュールのクリア」→「保存」の順にクリックします。

    5. 既存の再生フィルタを変更するには、「編集」をクリックし、「再生フィルタ・パラメータの変更」セクションでカレンダおよびクロックを使用して「フィルタ開始時間」および「終了時間」を変更してから、「保存」をクリックします。

    6. 既存の再生スケジュールを変更するには、「編集」をクリックし、「再生スケジュール・パラメータの変更」セクションでカレンダおよびクロックを使用して「スケジュール開始時間」および「終了時間」を変更してから、「保存」をクリックします。

  8. 再生内容と再生の開始時間および終了時間を決定します。

    1. 新規再生フィルタ・エントリを作成する場合:

      • 「再生フィルタ・パラメータの変更」領域のカレンダおよびクロック・コントロールをクリックし、開始時間および終了時間を追加します。

      • 「保存」をクリックします。

        図4-25で示すように、「アラート」ダイアログが表示されます。

        図4-25 再生スケジュールの確認ダイアログ

        図4-25の説明が続きます
        「図4-25 再生スケジュール確認ダイアログ」の説明

      • 「OK」をクリックします。

    2. 新規再生スケジュール・エントリを作成する場合は、次の手順を実行します。

      • 「再生スケジュール・パラメータの変更」領域のカレンダおよびクロック・コントロールをクリックし、開始時間および終了時間を追加し、スピードおよび繰返しモードを指定します。

        「スピード」: デフォルトのスピード値は1で、これが通常速度に対応しています。2の値は、イベントが元の記録速度の倍の速度で再生されることを意味します。同様に、0.5の値は、イベントが半分の速度で再生されることを意味します。

        「繰返し」: この値をtrueに設定すると、スケジュールされた終了時間または手動で再生を停止するまで再生を繰り返します。この値をfalseに設定すると、1回のみ再生されます。

      • 「保存」をクリックします。

        図4-26で示すように、「アラート」ダイアログが表示されます。

        図4-26 再生スケジュールの確認ダイアログ

        図4-26の説明が続きます
        「図4-26 再生スケジュール確認ダイアログ」の説明

      • 「OK」をクリックします。

    3. イベントをすぐに再生する場合は、次の手順を実行します。

    Oracle Stream Analytics Visualizerは、特定のステージが現在イベントを記録中または再生中かどうかのトラック情報を保持し、この情報に基づいて、「開始」および「終了」ボタンが状況に応じて有効化/無効化されます。

    Oracle Stream Analytics Visualizerを使用して再生を開始するとき、Oracle Stream Analyticsは、再生エントリからイベント・タイプ情報を使用し、すぐに再生を開始し、事前にスケジュールされた時間がある場合でも、変更はされません。「終了」ボタンを使用すると、すぐに再生セッションを停止します。

  9. 再生を終了する時間を決定します。

    1. 終了時間をスケジュールした場合、イベントの再生はその時間に終了します。

    2. イベントの再生をすぐに終了する場合は、「停止」をクリックします。

4.4 EPNにおけるイベントのトレースおよびインジェクト

イベント・インスペクタおよびストリーム・ビジュアライザを使用すると、様々な操作を実行できます。

  • 任意のHTTPパブリック/サブスクライブ・サーバー・チャネル上でイベントをトレースします。

  • イベント・インスペクタ・サービス動的HTTPパブリック/サブスクライブ・サーバー・チャネル上のEPNの任意のステージ上でイベントをトレースします。

  • イベントを任意のHTTPパブリック/サブスクライブ・サーバー・チャネルへインジェクトします。

  • イベント・インスペクタ・サービス動的HTTPパブリック/サブスクライブ・サーバー・チャネルを使用して、イベントをEPNの任意のステージへインジェクトします。

注意:

イベント・インスペクタのサービスは、Oracle Stream Analytics本番サーバーでは使用しません。開発するときにのみ使用します。

この項の内容は、次のとおりです。

詳細は、次を参照してください。

また、「EPNにおけるイベントの記録および再生」で説明されているように、イベントを記録および再生できます。

4.4.1 動的チャネルにおけるイベントのトレース

Oracle Stream Analytics Visualizerを使用すると、静的チャネルへ現在パブリッシュ中のメッセージを表示できます。

詳細は、「HTTPパブリッシュ/サブスクライブ・サーバーの管理」を参照してください。

動的チャネルにおけるイベントのトレース

  1. オプションで、イベントをトレースするようにHTTPパブリッシュ/サブスクライブ・サーバーを構成します。

    「イベント・インスペクタ・サービス」を参照してください。

  2. 左ペインで、アプリケーションがデプロイされているOracle Stream Analyticsサーバー・インスタンスの「アプリケーション」ノードに移動し、展開します。

  3. 「appname」を選択します。ここで、「appname」は、イベントをトレースおよび挿入する場所のアプリケーション名です。

  4. 右ペインで、「イベント処理ネットワーク」タブをクリックします。

    図4-28で示すように、「イベント処理ネットワーク」パネルが表示されます。

    図4-28 「イベント処理ネットワーク」パネル

    図4-28の説明が続きます
    「図4-28「イベント処理ネットワーク」パネル」の説明

  5. イベントをトレースする対象のステージを選択します。

    1. EPNダイアグラムを使用するには:

      • イベントをトレースする対象のステージを右クリックし、「トレース・イベント」を選択します。

    2. ドメイン・ツリーを使用するには:

      • 「appname」→「ステージ」ノードを展開します。ここで、「appname」は、イベントをトレースする場所のアプリケーション名です。

      • イベントをトレースする対象のステージをクリックします。

      • 右ペインで、イベントのトレースタブをクリックします。

    図4-29で示すように、「トレース・イベント」パネルが表示されます。

    図4-29 イベントのトレースタブ:「開始」

    図4-29の説明が続きます
    「図4-29「トレース・イベント」タブ: 「開始」」の説明

  6. 「起動」をクリックします。

    図4-30で示すように、「アラート」ダイアログが表示されます。

    図4-30 イベントのトレースの確認ダイアログ

    図4-30の説明が続きます
    「図4-30「トレース・イベント」確認ダイアログ」の説明

  7. 「OK」をクリックします。

    「ステータス」フィールドには「ON」と表示されます。

    「チャネル名」フィールドには、このステージをパス・スルーするイベントが書き込まれる元となる動的チャネルが表示されます。イベント・インスペクタ・サービスのHTTPパブリッシュ/サブスクライブ・チャネルの名前は次のようになります。

    /SERVERNAME/APPLICATIONNAME/STAGENAME/output

    説明:

    • SERVERNAME: トレース対象のアプリケーションおよびステージが実行中のOracle Stream Analyticsサーバーの名前。

    • APPLICATIONNAME: トレース対象のステージを所有するOracle Stream Analyticsアプリケーションの名前。

    • STAGENAME: トレース対象のOracle Stream Analyticsアプリケーション・ステージの名前。

    たとえば: /NonClusteredServer/cql/orderCSVAdapter/output

  8. 最上位ペインで、ViewStreamをクリックします。

    図4-31で示されるように、「ストリーム・ビジュアライザ」パネルが表示されます。

    図4-31 「ストリーム・ビジュアライザ」(ViewStream) :「サブスクライブ」

    図4-31の説明が続きます
    「図4-31「ストリーム・ビジュアライザ」(ViewStream) :「サブスクライブ」」の説明

  9. 「パブリッシュ/サブスクライブ・サーバー名」プルダウン・メニューで、イベントのトレースに使用するHTTPパブリッシュ/サブスクライブ・サーバー名を選択します。

  10. 「クライアントの初期化」をクリックします。

  11. 「サブスクライブ」タブを選択します。

  12. 「リフレッシュ」をクリックします。

    「サブスクライブ」タブがリフレッシュされ、ステージの動的チャネルが表示されます。

  13. Oracle Stream Analyticsサーバーがメッセージをパブリッシュする先のチャネル名の横にあるラジオ・ボタンをクリックします。

    たとえば: /NonClusteredServer/cql/orderCSVAdapter/output

  14. 「サブスクライブ」をクリックします。

    サブスクリプション・テキスト・ボックスから受信された「出力」メッセージには、チャネルへパブリッシュされているイベントが表示されます。

    注意:

    Oracle Stream Analytics Visualizerがチャネルのサブスクライブに失敗した場合、次のようなエラーが「デバッグ・メッセージ」領域に表示されます。 

    14:25:54 GMT-0400: httpFaultHandler(): [RPC Fault faultString="Error #2096" faultCode="InvokeFailed" faultDetail="null"]

    次に、次を確認します。

    • Oracle Stream Analytics VisualizerのAdobe Flashおよびブラウザの前提条件を満たしていますか。「前提条件」を参照してください。

  15. サブスクリプション・テキストから「出力」メッセージをクリアするには、「テキストのクリア」をクリックします。

  16. チャネルのサブスクライブを解除するには、「サブスクライブ解除」をクリックします。

  17. イベントのトレースを停止するには、イベントをトレースするために構成したステージを選択します。

    1. EPNダイアグラムを使用するには:

      • イベントをトレースする対象のステージを右クリックし、「トレース・イベント」を選択します。

    2. ドメイン・ツリーを使用するには:

      • 「appname」→「ステージ」ノードを展開します。ここで、「appname」は、イベントをトレースおよび挿入する場所のアプリケーション名です。

      • イベントをトレースする対象のステージをクリックします。

      • 右ペインで、イベントのトレースタブをクリックします。

    図4-32で示すように、「トレース・イベント」パネルが表示されます。

    図4-32 イベントのトレースタブ:「停止」

    図4-32の説明が続きます
    「図4-32「トレース・イベント」タブ:「停止」」の説明

  18. 「停止」をクリックします。

    図4-33で示すように、「アラート」ダイアログが表示されます。

    図4-33 イベントのトレースの「停止」の確認ダイアログ

    図4-33の説明が続きます
    「図4-33「トレース・イベント」の「停止」の確認ダイアログ」の説明

  19. 「OK」をクリックします。

    「ステータス」フィールドには「OFF」と表示されます。

    「チャネル名」フィールドは空白です。

4.4.2 イベント・インスペクタ・サービス動的チャネルにおける単一イベントのインジェクト

イベント・インスペクタ・サービス動的チャネルを使用すると、単一の単純なイベントをタイプ別にEPNの任意のステージへインジェクトできます。

Oracle Stream Analytics Visualizerは、ネスト化されたJavaオブジェクトを持たない単純なJavaタイプのプロパティのみで構成される単純なイベント・タイプのみをサポートします。イベント・プロパティは、次のタイプに限定する必要があります:

  • プリミティブJavaタイプ

  • 単純なJavaタイプの値を持つJava配列またはコレクション

  • Date

  • BigDecimal

  • BigInteger

また、イベントをJSONメッセージとして指定することによって、より複雑なプロパティを持つイベントをインジェクトできます。詳細は、「イベント・インスペクタ・サービス動的チャネルにおけるJSON文字列イベントのインジェクト」を参照してください。

注意:

イベント・インスペクタのサービスは、Oracle Stream Analytics本番サーバーでは使用しません。開発するときにのみ使用します。

イベント・インスペクタ・サービス動的チャネルにおける単一イベントのインジェクト

  1. オプションで、イベントをトレースするようにHTTPパブリッシュ/サブスクライブ・サーバーを構成します。

    「イベント・インスペクタ・サービス」を参照してください。

  2. 左ペインで、アプリケーションがデプロイされているOracle Stream Analyticsサーバー・インスタンスの「アプリケーション」ノードに移動し、展開します。

  3. 「appname」を選択します。ここで、「appname」は、イベントをトレースおよび挿入する場所のアプリケーション名です。

  4. 右ペインで、「イベント処理ネットワーク」タブをクリックします。

    図4-34で示すように、「イベント処理ネットワーク」パネルが表示されます。

    図4-34 「イベント処理ネットワーク」パネル

    図4-34の説明が続きます
    「図4-34「イベント処理ネットワーク」パネル」の説明

  5. イベントをインジェクトする対象のステージを選択します。

    1. EPNダイアグラムを使用するには:

      • イベントを挿入する対象のステージを右クリックし、「インジェクト・イベント」を選択します。

    2. ドメイン・ツリーを使用するには:

      • 「appname」→「ステージ」ノードを展開します。ここで、「appname」は、イベントをトレースおよび挿入する場所のアプリケーション名です。

      • イベントを挿入する対象のステージをクリックします。

        イベント・シンクであるステージを選択していることを確認します。

      • 右ペインで、「イベントのインジェクト」タブをクリックします。

    図4-35で示すように、「インジェクト・イベント」パネルが表示されます。

    図4-35 「イベントのインジェクト」タブ:「開始」

    図4-35の説明が続きます
    「図4-35「インジェクト・イベント」タブ:「開始」」の説明

  6. 「起動」をクリックします。

    図4-36で示すように、「アラート」ダイアログが表示されます。

    図4-36 「イベントのインジェクト」の「開始」の確認ダイアログ

    図4-36の説明が続きます
    「図4-36「インジェクト・イベント」の「開始」確認ダイアログ」の説明

  7. 「OK」をクリックします。

    「ステータス」フィールドには「ON」と表示されます。

    「チャネル名」フィールドには、このステージをパス・スルーするイベントがインジェクトされる元となる動的チャネルが表示されます。イベント・インスペクタ・サービスのHTTPパブリッシュ/サブスクライブ・チャネルの名前は次のようになります。

    /SERVERNAME/APPLICATIONNAME/STAGENAME/input

    説明:

    • SERVERNAME: トレース対象のアプリケーションおよびステージが実行中のOracle Stream Analyticsサーバーの名前。

    • APPLICATIONNAME: トレース対象のステージを所有するOracle Stream Analyticsアプリケーションの名前。

    • STAGENAME: トレース対象のOracle Stream Analyticsアプリケーション・ステージの名前。

    例: /defaultserver/cql/orderChannel/input

  8. 最上位ペインで、ViewStreamをクリックします。

    図4-37で示されるように、「ストリーム・ビジュアライザ」パネルが表示されます。

    図4-37「ストリーム・ビジュアライザ」(ViewStream): 単独イベントのパブリッシュ

    図4-37の説明が続きます
    「図4-37「ストリーム・ビジュアライザ」(ViewStream): 単独イベントのパブリッシュ」の説明

  9. 「パブリッシュ/サブスクライブ・サーバー名」プルダウン・メニューで、イベントのトレースに使用するHTTPパブリッシュ/サブスクライブ・サーバー名を選択します。

  10. 「クライアントの初期化」をクリックします。

  11. 「パブリッシュ」タブを選択します。

  12. 「リフレッシュ」をクリックします。

    「パブリッシュ」タブがリフレッシュされ、ステージの動的チャネルが表示されます。

  13. Oracle Stream Analyticsサーバーがメッセージをインジェクトする先のチャネル名の横にあるラジオ・ボタンをクリックします。

    たとえば: /NonClusteredServer/cql/orderCSVAdapter/output

  14. 「入力方法」ラジオ・ボタン・グループから、「フォーム・ベース・イベント」を選択します。

  15. 「イベント・タイプ」プルダウン・メニューから、イベント・タイプを選択します。

    「ストリームの表示」パネルが更新され、選択するイベント・タイプの属性のリストが示されます。

    たとえば、図4-37は、DataStockTickイベントの属性を示しています。これには次の属性が含まれます。

    • Price

    • Symbol

    • PercChange

    • Volume

    • LastPrice

    注意:

    ストリーム・イベント・タイプの表示プルダウン・メニューでは、「イベント・インスペクタ・サービス動的チャネルにおける単一イベントのインジェクト」で説明している制約を満たすイベント・タイプ・リポジトリで定義されたすべてのイベントのリストが示されます。より複雑なイベントをインジェクトするには、「イベント・インスペクタ・サービス動的チャネルにおけるJSON文字列イベントのインジェクト」を参照してください。

  16. 選択したイベント・タイプの属性を構成します。

    マウスアイコンを属性フィールドの上に重ねると、属性のデータ型を示すツールチップが表示されます。

  17. 「パブリッシュ」をクリックします。

    Oracle Stream Analytics Visualizerは、イベント・インスペクタ・サービス動的チャネル上でイベントをパブリッシュし、そのイベントはチャネルが識別するステージによって受信および処理されます。

  18. イベントのインジェクトを停止するには、イベントをインジェクトするために構成したステージを選択します。

    1. EPNダイアグラムを使用するには:

      • イベントを挿入する対象のステージを右クリックし、「インジェクト・イベント」を選択します。

    2. ドメイン・ツリーを使用するには:

      • 「appname」→「ステージ」ノードを展開します。ここで、「appname」は、イベントをトレースおよび挿入する場所のアプリケーション名です。

      • イベントを挿入する対象のステージをクリックします。

        イベント・シンクであるステージを選択していることを確認します。

      • 右ペインで、「イベントのインジェクト」タブをクリックします。

    図4-38で示すように、「インジェクト・イベント」パネルが表示されます。

    図4-38 「イベントのインジェクト」タブ:「停止」

    図4-38の説明が続きます
    「図4-38「インジェクト・イベント」タブ:「停止」」の説明

  19. 「停止」をクリックします。

    図4-39で示すように、「アラート」ダイアログが表示されます。

    図4-39 「イベントのインジェクト」の「停止」の確認ダイアログ

    図4-39の説明が続きます
    「図4-39「インジェクト・イベント」の「停止」の確認ダイアログ」の説明

  20. 「OK」をクリックします。

    「ステータス」フィールドには「OFF」と表示されます。

    「チャネル名」フィールドは空白です。

4.4.3 イベント・インスペクタ・サービス動的チャネルにおけるJSON文字列イベントのインジェクト

単一のイベントを直接HTTPパブリッシュ/サブスクライブ・チャネルへJSON形式の文字列としてインジェクトできます。JSONが表現できる任意のイベント・プロパティを使用できます。

また、単純な、前から存在するイベントをインジェクトできます。詳細は、「イベント・インスペクタ・サービス動的チャネルにおける単一イベントのインジェクト」を参照してください。

注意:

イベント・インスペクタのサービスは、Oracle Stream Analytics本番サーバーでは使用しません。開発するときにのみ使用します。

イベント・インスペクタ・サービス動的チャネルにおけるJSON文字列としてのイベントのインジェクト

  1. オプションで、イベントをトレースするようにHTTPパブリッシュ/サブスクライブ・サーバーを構成します。

    「イベント・インスペクタ・サービス」を参照してください。

  2. 左ペインで、アプリケーションがデプロイされているOracle Stream Analyticsサーバー・インスタンスの「アプリケーション」ノードに移動し、展開します。

  3. 「appname」を選択します。ここで、「appname」は、イベントをトレースおよび挿入する場所のアプリケーション名です。

  4. 右ペインで、「イベント処理ネットワーク」タブをクリックします。

    図4-40で示すように、「イベント処理ネットワーク」パネルが表示されます。

    図4-40 「イベント処理ネットワーク」パネル

    図4-40の説明が続きます
    「図4-40「イベント処理ネットワーク」パネル」の説明

  5. イベントをインジェクトする対象のステージを選択します。

    1. EPNダイアグラムを使用するには:

      • イベントを挿入する対象のステージを右クリックし、「インジェクト・イベント」を選択します。

    2. ドメイン・ツリーを使用するには:

      • 「appname」→「ステージ」ノードを展開します。ここで、「appname」は、イベントをトレースおよび挿入する場所のアプリケーション名です。

      • イベントを挿入する対象のステージをクリックします。

      • 右ペインで、「イベントのインジェクト」タブをクリックします。

    図4-41で示すように、「インジェクト・イベント」パネルが表示されます。

    図4-41 「イベントのインジェクト」タブ:「開始」

    図4-41の説明が続きます
    「図4-41「インジェクト・イベント」タブ:「開始」」の説明

  6. 「起動」をクリックします。

    図4-42で示すように、「アラート」ダイアログが表示されます。

    図4-42 「イベントのインジェクト」の「開始」の確認ダイアログ

    図4-42の説明が続きます
    「図4-42「インジェクト・イベント」の「開始」確認ダイアログ」の説明

  7. 「OK」をクリックします。

    「ステータス」フィールドには「ON」と表示されます。

    「チャネル名」フィールドには、このステージをパス・スルーするイベントがインジェクトされる元となる動的チャネルが表示されます。イベント・インスペクタ・サービスのHTTPパブリッシュ/サブスクライブ・チャネルの名前は次のようになります。

    /SERVERNAME/APPLICATIONNAME/STAGENAME/input

    説明:

    • SERVERNAME: トレース対象のアプリケーションおよびステージが実行中のOracle Stream Analyticsサーバーの名前。

    • APPLICATIONNAME: トレース対象のステージを所有するOracle Stream Analyticsアプリケーションの名前。

    • STAGENAME: トレース対象のOracle Stream Analyticsアプリケーション・ステージの名前。

    たとえば: /NonClusteredServer/cql/orderCSVAdapter/input

  8. 最上位ペインで、ViewStreamをクリックします。

    図4-43で示されるように、「ストリーム・ビジュアライザ」パネルが表示されます。

    図4-43「ストリーム・ビジュアライザ」(ViewStream): JSONイベントのパブリッシュ

    図4-43の説明が続きます
    「図4-43「ストリーム・ビジュアライザ」(ViewStream): JSONイベントのパブリッシュ」の説明

  9. 「パブリッシュ/サブスクライブ・サーバー名」プルダウン・メニューで、イベントのトレースに使用するHTTPパブリッシュ/サブスクライブ・サーバー名を選択します。

  10. 「クライアントの初期化」をクリックします。

  11. 「パブリッシュ」タブを選択します。

  12. 「リフレッシュ」をクリックします。

    「パブリッシュ」タブがリフレッシュされ、ステージの動的チャネルが表示されます。

  13. Oracle Stream Analyticsサーバーがメッセージをインジェクトする先のチャネル名の横にあるラジオ・ボタンをクリックします。

    たとえば: /NonClusteredServer/cql/orderCSVAdapter/output

  14. 「入力方法」ラジオ・ボタン・グループから、「JSON文字列」を選択します。

  15. テキスト・フィールドにJSON形式の文字列を入力します。

    {
    "event-type": "myEventType",
    "operation": "insert",
    "binding": "outbound",
    "value":{
        "firstname": "Jane",
        "lastname": "Doe",
        "phone": {
            "code": 12345,
            "number": "office"
        },
    }
}

  16. 「パブリッシュ」をクリックします。

    Oracle Stream Analytics Visualizerは、イベント・インスペクタ・サービス動的チャネル上でイベントをパブリッシュし、そのイベントはチャネルが識別するステージによって受信および処理されます。

  17. イベントのインジェクトを停止するには、イベントをインジェクトするために構成したステージを選択します。

    1. EPNダイアグラムを使用するには:

      • イベントを挿入する対象のステージを右クリックし、「インジェクト・イベント」を選択します。

    2. ドメイン・ツリーを使用するには:

      • 「appname」→「ステージ」ノードを展開します。ここで、「appname」は、イベントをトレースおよび挿入する場所のアプリケーション名です。

      • イベントを挿入する対象のステージをクリックします。

      • 右ペインで、「イベントのインジェクト」タブをクリックします。

    図4-44で示すように、「インジェクト・イベント」パネルが表示されます。

    図4-44 「イベントのインジェクト」タブ:「停止」

    図4-44の説明が続きます
    「図4-44「インジェクト・イベント」タブ:「停止」」の説明

  18. 「停止」をクリックします。

    図4-45で示すように、「アラート」ダイアログが表示されます。

    図4-45 「イベントのインジェクト」の「停止」の確認ダイアログ

    図4-45の説明が続きます
    「図4-45「インジェクト・イベント」の「停止」の確認ダイアログ」の説明

  19. 「OK」をクリックします。

    「ステータス」フィールドには「OFF」と表示されます。

    「チャネル名」フィールドは空白です。

4.5 EPNにおけるチャネル・ステージの監視

Oracle Stream Analytics Visualizerを使用すると、アプリケーションのイベント処理ネットワーク(EPN)の任意のチャネル・ステージ(ストリーム)を監視できます。

Oracle Stream Analyticsでは、チャネル・キューのイベント数を監視できるようにsizeメトリックが定義されています。

EPNにおけるチャネルの監視

  1. 左ペインで、アプリケーションがデプロイされているOracle Stream Analyticsサーバー・インスタンスの「アプリケーション」ノードに移動し、展開します。
  2. 「appname」を選択します。ここで、「appname」は、監視するアプリケーション名です。
  3. 右ペインで、「チャネル・モニター」タブをクリックします。

    図4-46で示すように、「チャネル・モニター」タブが表示されます。

    図4-46 「チャネル・モニター」タブ

    図4-46の説明が続きます
    「図4-46「チャネル・モニター」タブ」の説明
  4. チャネルを監視するには、「すべてのチャネル」リストのチャネルをクリックし、「チャネル・モニター」タブにある4つのグラフのいずれかにドラッグ・アンド・ドロップします。

    チャネル名は、グラフの下の色付きの凡例へ追加されます。色はグラフのチャネルの線に対応します。

    また、チャネル名は「監視対象チャネル」リストにも追加されます。

    グラフ上のすべてのチャネルを表示したり、任意の組合せで4つのグラフの中のチャネルを分散できます。

  5. グラフのスケールを変更するには、縦軸の左にあるスライダをクリックして上下にドラッグします。
  6. チャネルの監視を停止するには、「監視対象チャネル」リストにあるチャネルに関連付けられた「削除」ボタンをクリックします。

4.6 EPNステージまたはパスのスループットおよび待機時間の監視

Oracle Stream Analytics Visualizerを使用すると、アプリケーションのイベント処理ネットワーク(EPN)のステージの開始/終了ポイントまたは指定パスを監視できます。

Oracle Stream Analyticsは、各ステージまたはパスに関して監視できる次のメトリックを定義します。

  • 「スループット」: ステージによって処理されるイベント数。

  • 「平均待機時間」: イベントが指定されたEPNのパスを通過するためにかかる平均時間。

  • 「最大待機時間」: イベントが指定されたEPNのパスを通過するのにかかる最大時間。

  • 平均待機時間のしきい値: 指定した開始/終了ポイントの指定しきい値を超える平均待機時間の値を計算します。

EPNステージまたはパスのスループットおよび待機時間の監視

  1. 左ペインで、アプリケーションがデプロイされているOracle Stream Analyticsサーバー・インスタンスの「アプリケーション」ノードに移動し、展開します。

  2. 「appname」を選択します。ここで、「appname」は、スループットおよび待機時間を監視する対象のアプリケーション名です。

  3. 表示および構成するステージを選択します。

    1. EPNダイアグラムを使用するには:

      • 「イベント処理ネットワーク」タブをクリックします。

      • 監視対象のステージまたは監視対象のパスの最初のステージをダブルクリックします。

    2. ドメイン・ツリーを使用するには:

      • 「appname」→「ステージ」ノードを展開します。ここで、「appname」は、監視するアプリケーション名です。

      • 監視対象のステージまたは監視対象のパスの最初のステージをクリックします。

      • 右ペインで、「一般」タブをクリックします。

    ステージの「一般」タブが表示されます。たとえば、図4-47はチャネルの「一般」タブを示しています。

    図4-47 チャネル・ステージの「一般」タブ

    図4-47の説明が続きます
    「図4-47 チャネル・ステージの「一般」タブ」の説明

  4. 「診断の作成」ボタンをクリックします。

    図4-48で示すように、「新規待機時間プロファイル」アコーディオン・メニューが表示されます。これには次のタブが含まれます。

    • プロファイル情報

    • 待機時間

    • スループット

  5. 図4-48で示すように、アコーディオン・メニューの「プロファイル情報」タブをクリックし、表4-5でリストされている情報を入力します。

    図4-48 「新規待機時間プロファイル」画面 - 「プロファイル情報」タブ

    図4-48の説明が続きます
    「図4-48「新規待機時間プロファイル」画面 - 「プロファイル情報」タブ」の説明

    表4-5 「プロファイル情報」属性

    属性 説明

    プロファイル名

    作成する診断プロファイルの名前。

    状態

    すぐに使用するためにプロファイルを有効化する場合は、「オン」を選択します。

    すぐに使用するためにプロファイルを有効化しない場合は、「オフ」を選択します。

  6. 図4-49で示すように、アコーディオン・メニューの「待機時間」タブをクリックし、表4-6にリストで示されている情報を入力します。

    図4-49 「新規待機時間プロファイル」画面 - 「待機時間」タブ

    図4-49の説明が続きます
    「図4-49「新規待機時間プロファイル」画面 - 「待機時間」タブ」の説明

    表4-6 「待機時間」属性

    属性 説明

    最大待機時間メトリック

    イベントがステージまたはイベント処理ネットワークのサブセット(パス)を通過するのにかかる最大時間を監視することを指定します。

    平均待機時間メトリック

    イベントがステージまたはイベント処理ネットワークのサブセット(パス)を通過するのにかかる平均時間を監視することを指定します。

    平均収集間隔

    診断データを集める際の時間間隔を指定します。言い換えれば、「平均待機時間メトリック」が計算される間のスライディング・ウィンドウです。

    しきい値

    特定の値を超える待機時間メトリックのみ受信場合は、値を指定します。たとえば、待機時間が250 msを超える時点を識別する場合は、「しきい値」を250 msに指定します。

    この値は、「平均待機時間メトリック」を指定する場合にのみ有効化されます。

    開始ステージ名

    開始ステージに付与する名前を指定します。

    EPN内のパスではなく現在のステージのみ監視する場合は、「開始ステージ名」および「終了ステージ名」を現在のステージ名に設定します。

    「開始ステージ名」オプションは「エントリ」を、「終了ステージ名」は「終了」を選択します。

    終了ステージ名

    終了ステージに付与する名前を指定します。

    EPN内のパスを監視する場合、Oracle Stream Analytics Visualizerは現在のステージを開始パスであると仮定し、自動的に「開始ステージ名」フィールドにそれを選択します。

    パスの開始を現在のステージの「エントリ」または「終了」にするかどうかを指定します。次に、「終了ステージ名」または監視対象のパスの最後を選択し、パスの最後をステージの「エントリ」または「終了」にするかどうかを指定します。

  7. 図4-50で示すように、アコーディオン・メニューの「スループット」タブをクリックし、表4-7にリストで示されている情報を入力します。

    図4-50 「新規待機時間プロファイル」画面 - 「スループット」タブ

    図4-50の説明が続きます
    「図4-50「新規待機時間プロファイル」画面 - 「スループット」タブ」の説明

    表4-7 スループット属性

    属性 説明

    平均スループット・メトリック

    ステージを通過するイベントの平均スループットを監視することを指定します。

    ステージ名

    ステージの開始/終了でスループットを監視するかどうかを指定します。

    スループット間隔

    スループットが計算される際の期間を指定します。

    たとえば、「スループット間隔」を1に指定する場合、1秒間にステージを通過するイベント数が計算されます。これは、指定する「平均間隔」の期間に平均化されます。

    時間単位を「秒」、「ミリ秒」、または「マイクロ秒」として指定します。

    平均間隔

    平均スループットを収集する間隔を指定します。

    たとえば、「スループット間隔」を1に指定する場合、1秒間にステージを通過するイベント数が計算されます。これは、指定する「平均間隔」の期間に平均化されます。

    時間単位を「秒」、「ミリ秒」、または「マイクロ秒」として指定します。

  8. 「保存」をクリックします。

    パネルの右下角にポップアップ確認ダイアログが表示されます。

    保存した診断プロファイルは、図4-51で示すように、作成したステージの下の左のドメイン・ツリーに表示されます。

    図4-51 左のドメイン・ツリー: Mydiagprofile

    図4-51の説明が続きます
    「図4-51 左のドメイン・ツリー - Mydiagprofile」の説明

    注意:

    サーバーを再起動したり、作成した診断プロファイルを損失せずにアプリケーションのデプロイを解除できます。

  9. 「OK」をクリックします。

  10. 診断プロファイルをOracle Stream Analytics Visualizerダッシュボードへ追加します。

    1. 左のドメイン・ツリーで診断プロファイルを選択し、「ダッシュボードに追加」ボタンをクリックします。

    2. Oracle Stream Analytics Visualizerの最上位にある「ダッシュボード」リンクをクリックし、左ペインのドメイン・ツリーから作成した診断プロファイルを右ペインの下部の表にドラッグ・アンド・ドロップします。

  11. Oracle Stream Analytics Visualizerの上部にある「ダッシュボード」リンクをクリックします。

    図4-52で示すように、「管理イベント」およびパフォーマンス監視ペインを含む「ダッシュボード」画面が表示されます。

  12. 表の中の診断プロファイル名をクリックします。

    図4-52で示すように、待機時間およびスループットの情報がダッシュボードの中段にあるグラフに表示されます。

    図4-52 診断プロファイルを含むOracle Stream Analytics Visualizerダッシュボード

    図4-52の説明が続きます
    「図4-52 診断プロファイルを含むOracle Stream Analytics Visualizerダッシュボード」の説明

  13. パフォーマンス監視グラフを画面全体に拡大するには、「チャートの展開」をクリックします。

  14. パフォーマンス監視グラフを元のサイズに戻すには、「チャートの復元」をクリックします。

ダッシュボード上部の「管理イベント」セクションには、監視イベントの受信に関するアラートが表示されます。