Faça orion buscar dados do cosmos e publicar
-
21-12-2019 - |
Pergunta
Eu configurei uma assinatura entre Orion ContextBroker e Cosmos Bigdata usando Cygnus, e os dados estão persistidos adequadamente no Cosmos quando uma atualização é feita para Orion.
mas quero analisar os dados no cosmos e devolver os resultados para Orion e, finalmente, acessar os dados do resultado em Orion de "fora".
Como alguém faria isso?Claro, gostaria que a solução eu construí para ser tão "automatizada" quanto possível, mas principalmente eu só quero resolver esse problema.
Qualquer aconselhamento é muito apreciado!
Solução
Como a resposta geral (como também a questão é muito geral;), o que você precisa é um processo que o acesso às informações armazenadas no cosmos (usando o HDFS APIs -Such como WebHDFS ou Hive Queries, General MapReduce Trabalhos em Top of Hadoop, etc.), então implemente o lado do cliente da API da NGSI que Orion implementa para injetar elementos de contexto em Orion com base nas informações que você recuperou do cosmos. A operação chave para o fazer na API de Orion é updateContext .
O grau de automação dependeria de como você implementa esse processo. Pode ser tão automatizado quanto você quiser.
edit: Considerando este comentário de resposta, vou tentar adicionar mais detalhes.
O que quero dizer é desenvolver um software (vamos chamá-lo de APOS -A software) implementando o seguinte comportamento:
- .
- APOS irá pegar dados da Cosmos qualquer uma das interfaces fornecidas pelo Cosmos, isto é, WebHDFs / Httpfs, Hive, MapReduce trabalhos, etc.
- APOS processará os dados para produzir algum resultado
- APOs injetará esse resultado em Orion, usando a API de Resto de Orion descrita em o manual do usuário Orion . É particularmente útil para essa tarefa o UpdateContext Operação. De um ponto de vista do servidor cliente, Orion é um servidor expondo uma API de REST e APOs é o cliente interagindo com esse servidor.
É completamente até você Como implementar esta APOs e como orquestrar o fluxo de 1 a 3 (por exemplo, ele pode ser executado no modo de lote todas as meias, ser acionado pela interação do usuário em um portal da Web, etc.).
No momento presente, o FI-Ware não fornece nenhum facilitador genérico para converter dos dados do cosmos para o NGSI, dado que cada determinada realização das etapas 1 a 3 acima é diferente e depende do caso de uso. No entanto, observe que há componente de software chamado cygnus que implementa a outra maneira : De ngis para cosmos.