使猎户座从宇宙中获取数据并发布

Question

我已经使用Cygnus在Orion ContextBroker和Cosmos BigData之间建立了订阅，当对Orion进行更新时，数据在Cosmos中被正确地持久化。

但我想分析宇宙中的数据，并将结果返回给猎户座，最后从“外部”访问猎户座的结果数据。

一个人会怎么做？当然，我希望我构建的解决方案尽可能“自动化”，但大多数情况下，我只想解决这个问题。

任何建议都是非常感谢的！

Answer 1

作为一般响应(同样问题也是非常普遍的;)，您需要的是访问存储在宇宙中的信息的过程(使用HDFS -such作为WebHDFS或HttpFs-、Hive查询、Hadoop之上的一般MapReduce作业等)，然后实现Orion实现的NGSI API的客户端，以便根据从Cosmos检索的信息将上下文元素注入Orion。在Orion中这样做的关键操作是updateContext。

自动化程度将取决于您如何实现该过程。它可以像你想的那样自动化。

编辑：考虑到这个答案评论，我将尝试添加更多细节。

我的意思是开发一个实现以下行为的软件(让我们称它为APOS -A软件)：

1. APOS将从Cosmos获取任何由Cosmos提供的接口的数据，如WebHDFS/HttpFs、Hive、MapReduce作业等。
2. APOS将对数据进行处理以产生某些结果。
3. API将使用猎户座用户手册中描述的Orion将这一结果注入Orion。它对于该任务-- updateContext操作--特别有用。从客户机服务器的角度来看，Orion是一个服务器，它公开一个REST，API是客户机与该服务器交互。

完全取决于您如何实现此APOS，以及如何安排从1到3的流程(例如，它可以在整个午夜以批处理模式运行，通过web门户上的用户交互来触发，等等)。

目前，FI-WARE没有提供任何通用的使能器将宇宙数据转换为NGSI，因为上面步骤1到3的每个具体实现都是不同的，并且取决于用例。但是，请注意，有一个名为天鹅座的软件组件，它实现了另一种方式:从NGIS到宇宙。