| Oracle® Fusion Middleware Oracle Stream Explorerの使用 12c リリース(12.2.1) E72531-01 |
|
 前 |
 次 |
この章では、Oracle Stream Explorerでの探査について説明します。
この章の構成は、次のとおりです。
探査は、ビジネス・ロジックをイベント・フローに適用可能にするOracle Stream Explorer Event Processingアプリケーションです。探査は、ソースからストリーミングされるデータの視覚的表現です。探査では、データは次の形式で視覚的に表されます。
ライブ出力ストリーム - ライブ出力ストリームは、ストリーミング・データの形状を表形式で表示します。
折れ線グラフ - 折れ線グラフは、時系列データを視覚化する第一の方法です。X軸は時間の動きを表すために使用され、データは、時間が進むにつれ自然にスクロールします。Y軸は、時間が進むにつれての従属変数(つまり注目している変数)の変化を示すために使用されます。
散布図 - 時間ディメンションが重要でない場合、データは、散布図に示されることでわかりやすくなる場合があります。この場合、ユーザーはX軸とY軸に異なるイベント・プロパティを割り当てることができます。ただし、各軸上の値は数値変数である必要があります。X軸が説明変数、Y軸がレスポンス変数を表すことを思い出してください。このため、レスポンスまたは計算済フィールドを示すプロパティは、Y軸に自動割当てするのにより適した候補です。
時系列の場合、言うまでもなく、新しい値はグラフの右側に現れ、古い値は左側に消えていきます。ただし、この挙動は散布図に変換されません(新しい点が任意の場所に出現できるため)。
探査では、次のことが可能です。
1つ以上のストリームと参照をイベントとデータのソースとして使用すること
複数のイベントとデータ・ソースを相関させること
イベントとデータのフィルタ
イベントとデータのグループ化
集計関数のウィンドウを時間/イベントに基づいて指定すること
サマリーで使用する集計関数を指定すること
結果として生じるイベントに静的な文字列フィールドを追加すること
受信イベント(ロジック適用前)と、結果として生じるイベント(ロジック適用後)を表およびグラフ形式で、レビューすること
ターゲットを構成すること。
すべての探査は、次の組合せのメタデータを持っています。
名前
タグ
説明
作成者
作成日時
更新者
更新日時
お気に入りか否か。
タグ、説明およびお気に入りであることは、Exploration Editorで明示的に指定されます。作成および更新情報は、自動的に持続されます。
探査に複数のデータ・ソースが関連付けられる場合、データ・ソース間で論理的な関係が確立される必要があります。この論理的な関係は、相関と呼ばれます。
Oracle Stream Explorerでは、相関ルールを使用してデータ・ソースを結合できます。すべてのソースが相関している場合、さらにターゲットに向けて送信できる単一のイベント・ストリームが提供されます。相関させられていない様々なソースに由来する、互換性がある型のフィールドだけが、相関のオペランドとして使用できます。
ストリームと参照が相関していない場合、ソースを相関させるまで、探査は無効な状態のままです。相関させるまで、探査はサーバー上で更新されません。
出力のフィルタに使用できる条件は、フィルタと呼ばれます。出力にフィルタを適用すると、フィルタのすべてまたはいずれかに適合するイベントだけが表示されます。次の演算子を使用して左オペランドを右のオペランドと比較することによって、イベントをフィルタできます。
次と等しい
次と等しくない
次より低い
以下または同等
次より大きい
以上または同等
次を含む。
左オペランドは次のいずれかです。
探査内の任意のソースのフィールド
「サマリー」領域で定義されているサマリー。
右オペランドは次のいずれかです。
左オペランドの型と互換性を持つ型の定数
左オペランドのソースからのフィールドまたはフィールドのサマリー。
フィールドに関数(「サマリー」)を集計して、任意の組合せのフィールドにより、グループ化を適用できます。唯一の例外は、フィールドが両方のサマリーを持ってグループに含まれることができないということです。サマリーとグループ化のいずれかまたは両方を定義する場合、他のすべての非集計および非グループ化フィールドが結果の形状から自動的に除外されます。
サマリーまたはグループ化を定義する場合、出力に含められるフィールドは、「サマリー」および「グループ化」領域のフィールドのみです。サマリーを定義する場合、結果表に自動的に表示され、フィルタ領域にはこの新しく作成されたサマリーを基準にフィルタするオプションが表示されます。サマリーを削除または変更する場合、それがフィルタや出力で使用されているときは、フィルタや出力に影響を及ぼすため、このアクションを確認する必要があります。
この項では、探査を作成する方法を説明します。
探査を作成する手順:
「カタログ」に移動します。
「新規アイテムの作成」メニューの探査を選択します。
探査の作成ダイアログに情報を入力します。探査の作成画面を次に示します。
「名前」フィールドに探査の名前を入力します。
Descriptionフィールドに、ユーザーがこの探査について理解するのを助ける説明を入力します。
「タグ」フィールドに、探査に付けるタグを入力します。複数のタグを入力できます。
「ソース」フィールドで、探査のソースとしてストリームを選択します。これは、公開状態にあるもう一つの探査でもかまいません。
注意:
ソースが参照だけに基づく探査は作成できません。まずストリームから開始し、後から参照をソースとして追加する必要があります。
「作成」をクリックして探査の作成を完了します。新しい探査が、Exploration Editor内に開きます。新しく作成した探査は「カタログ」にも表示されます。
相関 - 探査で複数のソースが使用される場合は、ソース間に相関を追加する必要があります。
サマリー - 探査データのサマリーを追加し、データを適宜グループ化することができます。これはオプションです。
フィルタ - フィルタを追加し、探査に追加したサマリーに基づいてデータをさらにフィルタすることができます。これはオプションです。
ビジネス・ルール - 探査のデータにビジネス・ルールを追加できます。ビジネス・ルールは、アプリケーションに条件ロジックを構築します。これはオプションです。
式 - ストリーミング探査データに式を追加できます。式を使用すると、既存のデータに対して計算を実行することによって、ストリームに新しいデータ・フィールドを移入できます。
任意の時点で操作を中断するには、「取消」をクリックします。
探査を作成すると、探査がExploration Editor内に開きます。探査のパラメータを編集するオプションを持っています。既存の探査は編集または更新できます。探査のデータ・ソースを追加または変更できます。
探査を編集する手順:
カタログにナビゲートします。
編集または更新する探査を特定します。名前文字列または探査アイコンをクリックすると、編集する探査が開きます。Exploration Editorを次に示します。
データ・ソースを追加または削除するには、「ソース」フィールドのどこかをクリックします。複数のデータ・ソースがある場合、ソースを相関させる必要があります。
探査が複数のデータ・ソースを持っている場合、「相関」を定義します。
注意:
探査に対する変更は、ソースを相関させるまで適用されません。ソースを相関させずに変更を保存しようとすると、エラー・メッセージが表示されます。探査にサマリーを追加するには、「サマリー」領域の「サマリーの追加」をクリックします。
出力にフィルタを追加するには、「フィルタ」領域の「フィルタの追加」をクリックします。フィルタは、追加したサマリーに基づいてストリーミング・データをさらにフィルタします。
出力ストリームにタイムスタンプを追加することもできます。ストリーミング・データを取得したタイムスタンプが、ライブ出力ストリームの各行に表示されます。これはトグル・ボタンで、ライブ・データでのタイムスタンプのオン/オフを切り替えることができます。
注意:
ライブ出力ストリームに表示されるフィールドのみ、ターゲットに送信できます。
「グラフ」領域で、出力ストリームに表示するグラフの数を構成します。
ストリームの処理で使用される、時間とイベントに基づくウィンドウを指定するには、画面の右側にあるウィンドウ・ドロワーのアイコンをクリックします。
「範囲」ドロップダウン・リストで値を選択して、数値を指定します。この値は、データのストリームに関する期間の範囲を指定します。範囲は「現在」、「ナノ秒」、「マイクロ秒」、「ミリ秒」、「秒」、「分」、「時間」、「イベント」または「バインドなし」などの単位で定義されます。
「現在」は範囲が1ナノ秒の狭さであることを示し、「バインドなし」はサーバーが起動して以来の範囲とみなされることを示します。範囲が「現在」でない場合は、もう一つのフィールド、「評価頻度」が表示されます。
「評価頻度」ドロップダウン・リストで値を選択して、数値を指定します。この値は、システムがどれくらい頻繁に結果イベントを作成するかを定義します。
注意:
「評価頻度」は、「範囲」より長くはできません。
探査の情報を表示するには、右上隅の鉛筆アイコンをクリックします。
探査の「名前」、「説明」または「タグ」を更新するには、「情報の編集」をクリックします。
情報を更新したら、「完了」をクリックします。
行った変更を元に戻すには、右上隅の「変更を元に戻す」アイコンをクリックします。元に戻せるのは、次の変更のみです。
サマリーの追加、編集、削除
グループ化
フィルタの追加、編集、削除
範囲の指定。
注意:
公開アクションでは、元に戻す操作は使用できません。公開を元に戻すには、探査を非公開化する必要があります。
注意:
一度「元に戻す」をクリックすると、最後に行った変更だけが元に戻ります。
行った変更を再適用するには、右上隅の変更の再実行アイコンをクリックします。再実行できるのは、次の変更のみです。
サマリーの追加、編集、削除
グループ化
フィルタの追加、編集、削除
範囲の指定。
注意:
一度「やり直し」をクリックすると、最後に行った変更のみが再適用されます。
Exploration Editorについての説明を表示するには、右上隅のユーザー・アシスタントのアイコンをクリックします。このアイコンは、トグル・ボタンとして機能します。
注意:
探査を編集する場合、変更が実装されるためには、再びそれを公開する必要があります。
詳細をダウンストリームに送信するには、すべての探査にターゲットが構成される必要があります。探査が公開されない限り、構成されたターゲットにイベントをダウンストリーム送信できません。
ターゲットを構成する手順:
探査を作成する場合、デフォルトではドラフト状態にあります。アプリケーションの他のユーザーはそのドラフト探査を利用できません。探査は、それが公開されると公開済状態へ移動します。
公開された探査が削除済または非公開化された場合、探査はドラフト状態に移行します。
探査をOracle Stream Explorerのすべてのユーザーが利用できるようにするには、探査を公開する必要があります。公開された探査は:
別の探査のソースとして使用できます。
アプリケーションの他のユーザーから認識できます。
別のユーザーが非公開化するか、探査を削除するまで、実行状態にあります。
ターゲットに適用できます。
探査を公開する手順:
カタログにナビゲートします。
公開する探査を特定して、その名前またはアイコンをクリックします。
「アクション」メニューから「パブリッシュ」を選択します。
探査が公開され、確認メッセージが表示されます。探査が公開されると、次の図に示すようにカタログに表示されます。
コンシューマが誰も使用していない場合、次のシナリオで、探査を公開/再公開できます。
公開された探査を変更なしで再公開する場合
公開された探査の詳細を変更した後に公開する場合(公開された探査は、変更されると、ステータスがドラフトに移行します)。公開後、ドラフト・ステータスが公開ステータスに変更されます。
ターゲットが構成された探査を再公開する場合
2人以上のユーザーが変更後に探査を公開しようとすると、競合が発生します。競合を解決する際には、次の競合解決アクションが助けになります。
「上書き」をクリックして、行った変更を、公開されたバージョンに上書きします。
「破棄」をクリックすると、変更は破棄され、最新の公開済バージョンの探査に移動します。
複数ユーザーによる変更を保持する探査を異なる名前で公開するには、「クローン」をクリックします。
注意:
公開した探査を使用しているユーザーがいる場合は、依存性をクリアするまで、その探査を再公開することはできません。すでに公開されている探査を非公開化できます。
注意:
公開した探査を使用しているユーザーがいる場合は、依存性をすべてクリアするまで、その探査を非公開化することはできません。探査を非公開化する手順:
探査が非公開化され、確認メッセージが表示されます。探査が非公開化されると、カタログで、公開ステータスがドラフト・ステータスに変更されます。
注意:
いずれかのユーザーによって使用されている公開済探査は非公開化できません。
Oracle Stream Explorerを使用すると、探査をJARファイルとしてエクスポートし、ダウンロードして再利用することができます。公開されていない探査をエクスポートしようとすると、エラー・メッセージが表示されます。
エクスポートされた探査をJDeveloperにインポートして、アプリケーションを開発することができます。ただし、Oracle Stream Explorerにアプリケーションまたは探査をインポートすることはできません。
探査をエクスポートする手順:
カタログにナビゲートします。
エクスポートする公開済探査を特定して、それをクリックします。
「アクション」メニューから「エクスポート」を選択します。
探査のエクスポートのダイアログを次に示します。
「エクスポート・リスト」で探査の詳細をレビューします。「リソース」は、探査と、エクスポートされるその依存関係の名前です。「タイプ」は、リソース(探査/ソース)のタイプです。
必要な場合、「拡張オプション」で探査バンドルの詳細を編集/更新します。
「バンドルID」フィールドに値を入力します。これは、一意のOSGIバンドルであるOSGI Bundle-SymbolicNameパラメータで、エクスポートされたJARファイルの名前になります。
「バンドル名」フィールドに値を入力します。これは、探査がエクスポートされる際の名前です。
「エクスポート」をクリックして、探査のエクスポートを完了します。探査は、jarファイルとして保存されます。JARファイルはどこにでも保存できます。
任意の時点で操作を中断するには、「取消」をクリックします。
探査で、ユーザー資格証明(EDN、JMS、HTTP pubsub)が指定されているターゲットまたはソースが使用される場合、エクスポートされた探査は、暗号化パスワードのある資格証明を含みます。パスワードは、サーバー暗号化鍵で暗号化されます。通常、異なるサーバーは、異なる暗号化鍵を使用します。結果的に、サーバーに探査をデプロイする前に、暗号化パスワードを更新するか、プレーン・テキストのパスワードに変換する必要があります。そうしないと、暗号化エラーが表示されます。
探査をお気に入りにすることができます。探査をお気に入りにマークすると、カタログ上に多数の項目があっても、そのような探査を簡単に見つけて、移動できます。
探査をお気に入りとしてマークする手順:
探査が不要であることが確実になった場合、探査を削除できます。公開された探査を削除すると、ドラフト状態に移行します。ドラフト状態と公開済状態の探査がある場合、削除操作はドラフト探査を先に削除します。同じ探査について2回目に削除操作を起動すると、探査は削除されます。
探査を削除する手順:
確認のダイアログが表示されます。「OK」を選択すると、探査は削除されます。
デプロイメントがVisualizerから削除されたか、ネットワークの問題のため、EDNソースを開始できなかったか、ファイルがないためにCSVソースを開始できなかったか、対応するEvent ProcessingアプリケーションがOEP Server上でアンデプロイあるいは一時停止された場合、探査は無効状態に移行します。無効状態は、オブジェクト(ソースまたは公開済探査)にデプロイメントがないことを示します。
探査をリストアできます。リストア操作は、Oracle Stream Explorerで利用できる情報を使用して、無効状態のオブジェクトをデプロイしようと試みます。たとえば、ソースS1を使用する探査E1があり、双方とも無効状態にあるとします。探査上でリストア操作を起動すると、Oracle Stream Explorerはストリームと探査を順番にデプロイしようと試みます。
探査をリストアする手順:
リストア操作の結果に関する通知が表示されます。
