4 ストリームの使用

この章では、ストリームの詳細、ストリームの作成、およびストリームの編集について詳しく説明します。

この章の構成は、次のとおりです。

• ストリームについて

• ストリームの作成

• ストリームの編集

• ストリームのリストア

• ストリームをお気に入りとしてマーク

• ストリームの削除。

4.1 ストリームについて

イベント・ストリームは、単一タイプのイベントを生成するOracle Stream Analytics Event Processingアダプタ・ノードです。

Oracle Stream Analyticsのオブジェクトの分類においては、イベント・ストリームは、イベントの外部からの受け取りを担当するエンティティです。REST、JMS、Kafkaなど、様々な通信技術またはメッセージング・システムに基づく様々なストリーム・タイプがあります。

4.1.1 メタデータ

すべてのストリームは、次の組合せのメタデータを持っています。

• 名前

• タグ

• 説明

• 作成者

• 作成日時

• 更新者

• 更新日時

• お気に入りか否か。

4.2 ストリームの作成

ユーザーが探査を作成するには、ストリームが必要です。この項では、ストリームを作成する方法を説明します。ストリームの作成画面を次に示します。

図4-1 「ストリームの作成 - ソースの詳細」ダイアログ

「図4-1 「ストリームの作成 - ソースの詳細」ダイアログ」の説明

ストリームを作成する手順:

1. 「カタログ」に移動します。
2. 「新規アイテムの作成」メニューの「ストリーム」を選択します。
3. 「名前」フィールドにストリームの名前を入力します。これは必須フィールドです。
4. 「説明」フィールドに、ユーザーがストリームについて理解するのを助ける説明を入力します。これはオプションのフィールドです。
5. 「タグ」フィールドに、ストリームに付けるタグを入力します。複数のタグを入力できます。これはオプションのフィールドです。複数のタグを入力する場合は、カンマ、Enterキーまたはスペースで区切ります。

   注意:

   入力するタグは、Oracle Stream Analyticsでサポートされている業種を表す必要があります。既存のタグの詳細は、「ホームページ」を参照してください。

6. 「ソース・タイプ」フィールドから、ストリームに使用するストリーム・タイプを選択します。これは必須フィールドです。

   注意:

   ソース・タイプとしてEDNを選択した場合、フラット構造のXML要素のみを使用できます。XMLスキーマは他のスキーマをサポートしません。「ストリーム」ウィザードは、他のタイプのEDNはすべて表示しません。

7. Exploration Editorを起動して、このストリームをプライマリ・ソースとして利用する場合、このソースで探査を作成(Exploration Editorを起動)を選択します。
8. 「次へ」をクリックします。「タイプ・プロパティ」画面の次のフィールドに、選択したソース・タイプに基づいてデータを入力する必要があります。

   図4-2 「ストリームの作成 - 「タイプ・プロパティ」ダイアログ

   
   「図4-2 「ストリームの作成 - タイプ・プロパティ」ダイアログ」の説明

   表4-1 ストリームのソース・タイプ

   ソース・タイプ	データ・フィールド
   CSVファイル	ソース・タイプが「CSVファイル」の場合、次のフィールドにデータを入力する必要があります。 ソース・パス - ローカルCSVファイルをアップロードするか、ファイルが存在する場所のURLを入力します。これは必須フィールドです。 イベントの間隔 - イベントのリフレッシュ間隔。時間はミリ秒単位です。デフォルト値は、1000ミリ秒(1秒)です。 初期遅延 (ms) - データ・ストリーミングが開始されるまでの間隔。時間はミリ秒単位です。デフォルト値は0です。 CSVファイルのループ - ファイルの終わりに到達すると、自動的にファイルの最初から再開することで、CSVソースが常に実行していられるようにするオプションです。
   HTTP Subscriber	ソース・タイプがHTTP Subscriberの場合、次のフィールドにデータを入力する必要があります。 接続 - HTTPサブスクライバのタイプの接続。これは必須フィールドです。 Password- HTTP Subscriberにアクセスするパスワードこれは必須フィールドです。
   EDN	ソース・タイプが「EDN」の場合、次のフィールドにデータを入力する必要があります。 接続 - EDNタイプの接続これは必須フィールドです。
   JMS	ソース・タイプが「JMS」の場合、次のフィールドにデータを入力する必要があります。 接続 - JMSにアクセスするURL。これは必須フィールドです。 JNDI名 - JMSにアクセスするJNDI名(キューまたはトピック)。これは必須フィールドです。
   REST	ソース・タイプが「REST」の場合、次のフィールドにデータを入力する必要があります。 コンテキスト・パス - REST Adapterのコンテキスト・パス。これは必須フィールドです。
   Coherenceキャッシュ	ソース・タイプが「Coherenceキャッシュ」の場合、次のフィールドにデータを入力する必要があります。 接続 - 「Coherenceキャッシュ」タイプの接続これは必須フィールドです。 キャッシュ名: キャッシュの名前。
   Kafka	ソース・タイプが「Kafka」の場合、次のフィールドにデータを入力する必要があります。 接続 - 「Kafka」タイプの接続これは必須フィールドです。 トピック名 — ストリームで使用されるトピック名。このトピック名は、接続の作成時に定義されている必要があります。これは必須フィールドです。 グループID — ストリームで使用されるグループID。このIDは、接続の作成時に定義されている必要があります。これはオプションのフィールドです。
   MQTT	ソース・タイプがMQTTの場合、次のフィールドにデータを入力する必要があります。 接続 - MQTTタイプの接続これは必須フィールドです。
   Twitter	ソース・タイプがTwitterの場合、次のフィールドにデータを入力する必要があります。 接続 - Twitterタイプの接続。これは必須フィールドです。 ハッシュタグ — ライブ出力ストリームに含める、カンマで区切られたハッシュタグ。これはオプションのフィールドです。 言語 — ライブ出力ストリームに含める、カンマで区切られた言語。これはオプションのフィールドです。 ユーザー — ライブ出力ストリームに含める、カンマで区切られたTwitterユーザーIDのリスト。これはオプションのフィールドです。 少なくとも1つのハッシュタグまたは「ユーザー」プロパティを指定する必要があります。 注意: ハッシュタグおよび「ユーザー」の両方を指定する場合、論理演算子ORが使用されます。詳細は、https://dev.twitter.com/streaming/reference/post/statuses/filterを参照してください。
   イベント・ジェネレータ	ソース・タイプがイベント・ジェネレータの場合、次のフィールドにデータを入力する必要があります。 間隔 (ms) - メッセージの間隔(ミリ秒)。これはオプションのフィールドです。 最小値 — 生成される最小の数値。これはオプションのフィールドです。 最大値 — 生成される最大の数値。これはオプションのフィールドです。 精度 — 小数の桁数を指定します。これはオプションのフィールドです。 文字列数 — 事前に生成された文字列の数。これはオプションのフィールドです。 最小単語数 — 生成された文字列内の最小単語数。これはオプションのフィールドです。 最大単語数 — 生成された文字列内の最大単語数。これはオプションのフィールドです。

9. 「次へ」をクリックします。「ストリームの作成 - 形状」画面が表示されます。

   図4-3 「ストリームの作成 - 形状」ダイアログ

   
   「図4-3 「ストリームの作成 - 形状」ダイアログ」の説明
10. 「形状」画面で手動マッピングまたは形状の選択を実行します。

    手動マッピングを実行する場合、データ・ソースの各フィールドにより表される値に適合する最適なデータ型を決定する必要があります。可能なデータ型は、String、Byte、Integer、Big int、Float、Double、Big decimal、Boolean、Timestampです。

    注意:

    形状名の入力はオプションです。形状を指定しない場合、この形状はドロップダウン・リストで再利用できません。

    形状を選択する場合、既存の構成はストリーム用に使用されます。

11. 「作成」をクリックしてストリームを作成します。新しいストリームがカタログに表示されます。
12. 任意の時点で操作を中断するには、「取消」をクリックします。

4.3 ストリームの編集

ストリームを作成したら、Oracle Stream Analyticsを使用してストリームを編集できます。

次の場合は、ストリームを編集できません。

• ストリームを使用している公開済探査がある場合

• 探査内からストリーム・ダイアログを開いている場合

ストリームを編集する手順:

1. 「カタログ」で、編集するストリームをクリックします。
2. 上部のソース・ダイアログの「編集」をクリックします。

   図4-4 「ソースの編集」ダイアログ

   
   「図4-4 「ソースの編集」ダイアログ」の説明

   注意:

   現リリースにおける各セクション・レベルでの「編集」の動作は、ストリームの編集ウィザードの起動です。これは、ストリームの編集 - 「ソースの詳細」画面が、表示されるデフォルトの画面であることを意味します。
3. ストリーム・ダイアログで、編集するデータを更新します。

   注意

   Sparkランタイムを使用している場合、データ・ソースのフィールドにGeometryのデータ型は使用できません。

   注意:

   Twitterタイプのストリームにハッシュタグおよび「ユーザー」の両方を指定する場合、論理演算子ORが使用されます。詳細は、https://dev.twitter.com/streaming/reference/post/statuses/filterを参照してください。
4. ストリームの編集 - 「タイプ・プロパティ」ダイアログで、CSVファイルのループを選択します。この機能によって、ファイルの終わりに到達すると、自動的にファイルの最初から再開することで、CSVソースが常に実行していられるようにします。

   図4-5 ストリームの編集 — CSVファイルのループ機能

   
   「図4-5 ストリームの編集 — CSVファイルのループ機能」の説明

   注意:

   この機能は、CSVソースのみに使用でき、他のタイプのソースやターゲットには使用できません。
5. ストリームの更新または編集が完了したら、「保存」をクリックします。
6. 任意の時点で操作を中断するには、「取消」をクリックします。
7. ストリーム・ダイアログで「完了」をクリックして、編集操作を完了します。

4.4 ストリームのリストア

ストリームまたは対応するEvent ProcessingアプリケーションがVisualizerでアンデプロイされている場合、ストリームは無効状態に移行します。Oracle Stream Analyticsを使用すると、無効状態にあるストリームをリストアできます。

探査をリストアする手順:

1. カタログで、無効状態のストリームを特定します。無効状態のストリームは、赤い十字のアイコンによって示されます。
2. デプロイメントの問題を修正して、ストリームをリストアするには、ストリームの右側にある「リストア」アイコンをクリックします。

   図4-6「リストア」アイコン

   
   「図4-6「リストア」アイコン」の説明

   リストア操作の結果に関する通知が表示されます。

4.5 ストリームをお気に入りとしてマーク

ストリームをお気に入りとしてマークすることができます。ストリームをお気に入りにマークすると、カタログ上に多数の項目があっても、そのようなストリームを簡単に見つけて、移動できます。

ストリームをお気に入りとしてマークする手順:

1. カタログで、お気に入りにマークするストリームを特定します。
2. そのストリームに対応する表の行の右側にある「お気に入り」アイコンをクリックすると、お気に入りとしてマークされます。このアイコンは、トグル・ボタンとして機能します。

   図4-7「お気に入り」アイコン

   
   「図4-7 「お気に入り」アイコン」の説明
3. お気に入りからストリームを削除するには、「お気に入り」ボタンをもう一度クリックします。

4.6 ストリームの削除

ストリームが不要であることが確実になった場合、ストリームを削除できます。ストリームが依存関係を持っている場合は削除できません。ストリームが依存関係を持つとは、いずれかのユーザーが使用している公開済探査の一部であることです。

依存関係があるストリームを削除するには、先に依存関係を削除する必要があります。

ストリームを削除する手順:

1. カタログで、削除するストリームを特定します。
2. ストリームの右側の「アクション」・メニューのアイテムの削除オプションをクリックして削除します。

   確認のダイアログが表示されます。「削除」を選択すると、ストリームは削除されます。なんらかの理由でストリームを削除しない場合は、「取消」をクリックします。