OCMOSからデータを取得して公開します
-
21-12-2019 - |
質問
Cygnusを使用してOrion ContextBrokerとCosmos BigDataの間にサブスクリプションを設定し、更新がOrionに加えられたときにデータが適切に永続化されます。
しかし、私はCosmosのデータを分析し、結果をOrionに戻し、最後に "外部"からのORIONの結果データにアクセスします。
これをどうやってしますか?もちろん、私はできるだけ「自動化」になるように構築するソリューションを望みますが、ほとんどこの問題を解決したいだけです。
あらゆるアドバイスは大いに感謝されています!
解決
一般的な応答として(問題は非常に一般的です。)、必要なものは、COSMOSに格納されている情報にアクセスするプロセスです(HDFS API -SUCHを使用してWebHDFSまたはHTTPFS-、HIVEクエリ、一般マプレーージョブ)。その後、Cosmosから取得した情報に基づいてコンテキスト要素をORINEに挿入するために、ORIONを実装するために、NGSI APIのクライアント側を実装します。 ORION APIの中で行うためのキー操作は updateContext
自動化度は、そのプロセスの実装方法によって異なります。それはあなたが望むのと同じくらい自動化することができます。
編集:この回答のコメントを考えると、詳細をさらに追加しようとします。
私がどんな意味のあることは、次の動作を実行するソフトウェアを開発することです(ソフトウェアの一枚を呼び出しましょう)。
- aposは、Cosmos、すなわちwebhdfs / httpfs、hive、mapreduce jobsなどのインターフェースのいずれかからデータをグラブします。
- aposはデータを処理していくつかの結果を生成します
- 'がオリオンREST APIは、 ORionのユーザーマニュアル。そのタスクに特に便利です。 updateContext 操作。クライアント - サーバの観点から、ORIONはREST APIを公開するサーバであり、APOはそのサーバと対話するクライアントです。
このAPOを実装する方法と1から3のフローを作成する方法(例えば、すべてのミッドナイトで実行することができます)は、このAPOSを実行する方法(例えば、すべてのミッドナイトで実行できます。)。
現時点では、上記のステップ1~3の特定のステップ1~3の実現が異なることを考慮して、COSMOSデータからNGSIに変換するための一般的なイネーブラを提供しておらず、ユースケースによって異なります。ただし、 cygnus に該当するソフトウェアコンポーネントがあることに注意してください。 :NGISからCosmosへ。