カスタムストリーミング処理機能とThings Cloud
デバイスとセンサーを Things Cloud に接続することができます。 コンセプトガイドの デバイスのインターフェース および デバイス統合 ガイドの MQTT を使用したデバイス統合 をご覧ください。
センサーは Things Cloud のMeasurementまたはEventオブジェクトを生成し、デバイスは Things Cloud プラットフォーム内で作成されたOperationオブジェクトを受け取ることができます。これらのオブジェクト (Measurement、Event、Operation) はすべて Things Cloud プラットフォーム内の単一のデバイスに関連付けられます。 デバイスには複数のタイプのメジャーメントが関連付けられている場合があり、各デバイスがサポートするメジャーメントのタイプは、他のデバイスと同じである場合もあれば、他のデバイスと異なる場合もあります。デバイスが Things Cloud に接続されると、これらのデバイスに関する情報が Things Cloud インベントリに保存されます。これらはデバイス管理アプリケーションで表示され、そのデバイスに関連付けられたMeasurement、Event、またはOperationオブジェクトを表示するために使用することもできます。 詳細については、ユーザーガイドのデバイス管理をご覧ください。
ストリーミング分析アプリケーションを使用すると、独自のロジックを IoT ソリューションに追加して、デバイスまたは他のデータ ソースから受信したデータを即座に処理できます。 これらのユーザー定義の操作は、たとえば、新しい受信データについてアプリケーションに警告したり、受信したデータに基づいて新しい操作を作成したり (センサーのしきい値を超えたときにアラームを送信するなど)、デバイス上で操作をトリガーしたりできます。
典型的なリアルタイム分析のユースケースは次のとおりです。
- 遠隔制御: 温度が40度以上に上昇した場合、デバイスの電源を切る
- 検証: 負のメーター読み取り値または前よりも低いメーター読み取り値を破棄する
- 派生データ: 自動販売機1台当たりの1日あたりの販売取引量を算出
- 集計: 顧客の1日当たりの自動販売機の売上を合計する
- 通知: 保有する機械の1つに停電が発生した場合、メールを送信
- 圧縮: すべての車の位置の更新を5分ごとにのみ保存（ただし、ユーザーインターフェースに表示している車のリアルタイムデータは送信する）
Things Cloud プラットフォームには、Things Cloud プラットフォームによって管理され (手動で開始または停止されません)、 Things Cloud と通信するよう事前に構成された Apama コリレーターコンポーネントが含まれています。 このコリレーターは、Analytics Builder ランタイムをホストし、EPL アプリを使用して追加された操作ロジックも実行します。 操作ロジックは Apama のイベント処理言語 (Apama EPL) に基づいています。
備考
このドキュメントは、Apama アプリケーション開発に関する基本的な知識があることを前提としています。 詳細については、Apama ドキュメント をご覧ください。
ホーム画面
アプリケーションスイッチャー を使用して、ストリーミング分析アプリケーションにアクセスします。
ストリーミング分析アプリケーションのホーム画面では、アプリケーションのさまざまなページに移動できます。 これらは、Analytics Builder と EPL アプリ です。 これらのページには、ホーム画面の対応する 開く ボタンを使用するか、左側のナビゲータを使用してアクセスできます。
ページにさらに多くのスペースが必要な場合は、ナビゲータを非表示にすることができます。 トップバーの左端にある小さな矢印をクリックしてナビゲータの表示を切り替えます。
ホーム画面にはスマートルールに関する情報も表示されます。スマートルールの作成と管理は、コックピットアプリケーションで行います。 詳細については、ユーザーガイド の コックピット > スマートルール をご覧ください。
ホーム画面とナビゲータには、使用が許可されている項目のエントリのみが表示されます。 テナントがサブスクライブしている Apama-ctrl マイクロサービスのバージョンに応じて異なります。 マイクロサービス ランタイムとアプリケーション および ストリーミング分析アプリケーションのホーム画面のカスタマイズ をご覧ください。
Analytics Builder
ストリーミング分析アプリケーションの Analytics Builder ページを使用すると、新しいデータを生成したりイベントを出力したりするためにストリーミング データを変換または分析する分析モデルを構築できます。 モデルはリアルタイムでデータを処理できます。
モデルはデバイスやセンサーのメジャーメントと対話します。 モデルはデバイスからMeasurementオブジェクトとEventオブジェクトを受け取ることができ、これらはモデル内で実行される計算やパターン検出への入力を提供します。 モデルは、センサーから導出された値 (平均気温など) を表す新しいMeasurementオブジェクトを作成したり、メジャーメントを他の分析モデルへの入力として使用したりできます (モデル間の接続)。 モデルは、デバイスに送信される新しいOperationオブジェクトを作成して、デバイスを制御できます (たとえば、警報ベルを鳴らす、画面にメッセージを表示する、デバイスのスイッチをオフにするなど)。 モデルは Things Cloud インベントリにも保存されますが、モデルマネージャーを介してインポートまたはエクスポートできます。
事前に構築されたブロックをモデルに結合することにより、グラフィカルな環境でモデルを構築します。 モデル内のブロックはロジックをパッケージ化しており、多数の入力、出力、パラメーターを持っています。 各ブロックは、センサーからのデータの受信、計算の実行、条件の検出、出力信号の生成など、特定の機能を実装します。 ブロックの構成を定義し、ワイヤー を使用してブロックを接続します。 モデルを編集したり、履歴データを使用して展開をシミュレートしたり、ライブシステムに対して実行したりできます。 詳細については、Analytics Builder をご覧ください。
Analytics Builder で提供されるブロックが必要なロジックを実装していない場合は、カスタムブロックを構築することもできます。 独自のブロックの作成 をご覧ください。
さまざまなテナントオプションを設定することで、Analytics Builderのいくつかの側面をカスタマイズできます。 詳細については、構成 をご覧ください。
EPL アプリ
ストリーミング分析アプリケーションの EPL アプリ ページでは、Apama のイベント処理言語 (Apama EPL) でビジネス ロジックを作成できます。これにより、テキストベースのプログラミング言語の機能と柔軟性が向上します。 これは、より複雑なロジックが必要な場合、またはロジックが分析モデルのパターンに適合しない場合の代替手段です。
Apama EPL で記述された EPL アプリ (つまり、単一の *.mon ファイル) を Things Cloud 内で直接開発することができます。 既存の *.mon ファイルを EPL アプリとして Things Cloud にインポートすることもできます。 ストリーミング分析アプリケーションから EPL アプリをアクティブ化する場合は、それを Things Cloud にデプロイします。 例を含む詳細情報については、EPL アプリ をご覧ください。
簡単に始める方法は、EPL エディターからアクセスできる EPL サンプルのコードを調べることです。 EPL アプリの作成方法とサンプルへのアクセス方法については、ストリーミング分析アプリケーションを使用したアプリケーションの開発 をご覧ください。 まず、「計測値がしきい値を超えた場合にアラームを作成する」など、温度測定を含む単純なサンプルの 1 つを使用します。 このサンプルを使用すると、すぐに結果を確認できます。 独自の EPL コードをサンプルに追加し、変更を試してみてください。
Things Cloud と対話するには、Apama API を使用します。 詳細については、EPL の API リファレンス (ApamaDoc) の com.apama.cumulocity パッケージをご覧ください。これは Apama ドキュメントの一部です。
前提条件
ブラウザ
ストリーミング分析アプリケーションは、Things Cloud と同じブラウザをサポートしますが、次の例外があります: スマートフォンとタブレットのブラウザはサポートされていません。
権限
Analytics Builder を使用するには、少なくとも次の権限が必要です。
| 権限のタイプ | 権限レベル |
|---|---|
| CEP 管理 | 管理者 |
| オプション管理 | 読み取り |
| インベントリ | 読み取り |
これは通常、これらの権限を持つグローバル ロールを使用し、そのロールが Analytics Builder アプリケーションにアクセスできるようにすることで実現されます。 詳細については、ユーザーガイドの管理 > 権限の管理をご覧ください。
EPL アプリを使用するには、次の権限のみが必要です。
| 権限のタイプ | 権限レベル |
|---|---|
| CEP 管理 | 管理者 |
マイクロサービスのランタイムとアプリケーション
分析モデル、EPL アプリ、スマート ルールは、Apama-ctrl マイクロサービスで実行されます。 これにはテナントごとの独立領域があります。つまり、サブスクライブされた各テナントには、専用のリソース (つまり、メモリーと CPU の使用量) を持つ Apama コンテナの独自のインスタンスがあります。 コンテナは他のテナントから分離されているため、他のコンテナ上の高い CPU 負荷やメモリーの問題は個別に追跡され、リソースが割り当てられます。
| 以下をするには | 以下のものが必要 |
|---|---|
| 分析モデルの構築 | Apama-ctrl マイクロサービスとストリーミング分析アプリケーション |
| EPL アプリの開発 | Apama-ctrl マイクロサービスとストリーミング分析アプリケーション |
| スマートルールの使用 | Apama-ctrl マイクロサービスとスマートルールマイクロサービス (Things Cloud に標準で含まれます) |
ユーザー ガイドの次のセクションもご覧ください。
テナントに Apama-ctrl-smartrules マイクロサービスがサブスクライブされている場合、Analytics Builder ページと EPL アプリ ページは ストリーミング分析アプリケーションで使用できません。
機能の追加については、製品サポート にお問い合わせください。
注意事項
親テナントでカスタムストリーミング処理機能を利用している場合、サブテナントに対するApama-ctrl マイクロサービスに関して一部制限がある場合があります。以下のケースに当てはまった場合は、ワークアラウンドとして製品サポート にお問い合わせください。
対象 |
事象 | ワークアラウンド |
|---|---|---|
| カスタムストリーミング処理機能利用中の親テナントから新規作成するサブテナント | カスタムストリーミング処理機能を利用している親テナントをご利用中に、サブテナントを新規に作成された場合、新規作成したサブテナントではスマートルールが利用できません。 なお、新規作成したサブテナントにApamaエンジン Apama-ctrl-○c-○g（○は数字）を適用することでスマートルール機能をご利用になれますが、別途サブテナント分のカスタムストリーミング処理機能利用料金が発生いたします。そのため、サブテナントではカスタムストリーミング処理機能は不要で、かつスマートルールのみをご利用になりたい場合には、お申し出ください。 |
新規作成したサブテナントにてスマートルールをご利用希望の場合、Things Cloud Support よりスマートルールを利用したい旨をお申し出ください。なお、弊社作業には5営業日ほどお時間を要します。 |
| カスタムストリーミング処理機能利用中のサブテナント | お客様にてサブテナントのApamaエンジンを、Apama-ctrl-○c-○g（○は数字）から Apama-ctrl-smartrules（スマートルール専用エンジン）のものに変更することはできません。サブテナントのカスタムストリーミング処理機能で利用する以下アプリケーションを削除した場合、スマートルールが利用できない状態となります。 ・Apama-ctrl-○c-○g（○は数字） ・ストリーミング分析 |
該当テナントにてスマートルールをご利用希望の場合、お客様にてカスタムルールの削除を実施後、 Things Cloud Support よりスマートルールを利用したい旨をお申し出ください。なお、弊社作業には5営業日ほどお時間を要します。 |
言語設定
ストリーミング分析アプリケーションのユーザー インターフェースが表示される言語は、Things Cloud のユーザー設定によって異なります。 詳細については、ユーザー ガイド の はじめに > ユーザー オプションと設定 をご覧ください。
Things Cloud またはブラウザが ストリーミング分析アプリケーションで現在サポートされていない言語に設定されている場合、ユーザー インターフェースはデフォルトの言語である英語で表示されます。