OCMOSからデータを取得して公開します

Question

Cygnusを使用してOrion ContextBrokerとCosmos BigDataの間にサブスクリプションを設定し、更新がOrionに加えられたときにデータが適切に永続化されます。

しかし、私はCosmosのデータを分析し、結果をOrionに戻し、最後に "外部"からのORIONの結果データにアクセスします。

これをどうやってしますか？もちろん、私はできるだけ「自動化」になるように構築するソリューションを望みますが、ほとんどこの問題を解決したいだけです。

あらゆるアドバイスは大いに感謝されています！

Answer 1

一般的な応答として（問題は非常に一般的です。）、必要なものは、COSMOSに格納されている情報にアクセスするプロセスです（HDFS API -SUCHを使用してWebHDFSまたはHTTPFS-、HIVEクエリ、一般マプレーージョブ）。その後、Cosmosから取得した情報に基づいてコンテキスト要素をORINEに挿入するために、ORIONを実装するために、NGSI APIのクライアント側を実装します。 ORION APIの中で行うためのキー操作は updateContext

自動化度は、そのプロセスの実装方法によって異なります。それはあなたが望むのと同じくらい自動化することができます。

編集：この回答のコメントを考えると、詳細をさらに追加しようとします。

私がどんな意味のあることは、次の動作を実行するソフトウェアを開発することです（ソフトウェアの一枚を呼び出しましょう）。

1. aposは、Cosmos、すなわちwebhdfs / httpfs、hive、mapreduce jobsなどのインターフェースのいずれかからデータをグラブします。
2. aposはデータを処理していくつかの結果を生成します
3. 'がオリオンREST APIは、 ORionのユーザーマニュアル。そのタスクに特に便利です。 updateContext 操作。クライアント - サーバの観点から、ORIONはREST APIを公開するサーバであり、APOはそのサーバと対話するクライアントです。

このAPOを実装する方法と1から3のフローを作成する方法（例えば、すべてのミッドナイトで実行することができます）は、このAPOSを実行する方法（例えば、すべてのミッドナイトで実行できます。）。

現時点では、上記のステップ1~3の特定のステップ1~3の実現が異なることを考慮して、COSMOSデータからNGSIに変換するための一般的なイネーブラを提供しておらず、ユースケースによって異なります。ただし、 cygnus に該当するソフトウェアコンポーネントがあることに注意してください。 ：NGISからCosmosへ。