让 Orion 从 Cosmos 获取数据并发布

Question

我已使用 Cygnus 在 Orion ContextBroker 和 Cosmos BigData 之间设置了订阅，并且当对 Orion 进行更新时，数据会正确保留在 Cosmos 中。

但我想分析Cosmos中的数据并将结果返回给Orion，最后从“外部”访问Orion中的结果数据。

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

非常感谢任何建议！

Answer 1

作为一般性回答（问题也很笼统；），您需要的是一个访问存储在 Cosmos 中的信息的过程（使用 HDFS API（例如 WebHDFS 或 HttpFs）、Hive 查询、Hadoop 之上的常规 MapReduce 作业）等），然后实现 Orion 实现的 NGSI API 客户端，以便根据从 Cosmos 检索到的信息将上下文元素注入到 Orion 中。在 Orion API 中执行此操作的关键操作是 更新上下文.

自动化程度取决于您如何实施该流程。它可以根据您的需要实现自动化。

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

我的意思是开发一个软件（我们称之为 APOS -A Piece Of Software），实现以下行为：

1. APOS 将从 Cosmos 提供的任何接口获取数据，即WebHDFS/HttpFs、Hive、MapReduce 作业等。
2. APOS 将处理数据以产生一些结果
3. APOS 将使用 Orion REST API 中描述的 Orion REST API 将该结果注入到 Orion 中 Orion 用户手册. 。对于该任务特别有用 更新上下文 手术。从客户端-服务器的角度来看，Orion 是公开 REST API 的服务器，而 APOS 是与该服务器交互的客户端。

如何实现此 APOS 以及如何编排从 1 到 3 的流程完全取决于您（例如它可以在整个午夜以批处理模式运行，由门户网站上的用户交互触发等）。

目前，FI-WARE 不提供任何通用启用器来从 Cosmos 数据转换为 NGSI，因为上述步骤 1 到 3 的每个特定实现都是不同的并且取决于用例。但是，请注意，有一个名为 天鹅座 它实现了另一种方式：从 NGIS 到 Cosmos。