Faire chercher des données d'orion à partir de cosmos et publie

Question

J'ai configuré un abonnement entre Orion contextBroker et Cosmos Bigdata à l'aide de Cygnus et les données sont correctement persistées dans Cosmos lorsqu'une mise à jour est faite à Orion.

Mais je veux analyser les données dans Cosmos et renvoyer les résultats à Orion, et enfin accéder aux données de résultat dans Orion de "Extérieur".

Comment faire cela?Bien sûr, j'aimerais que la solution que je construise soit aussi "automatisée" que possible, mais surtout je veux juste résoudre ce problème.

Tout conseiller est très apprécié!

Answer 1

comme une réponse générale (comme la question est également très générale;), ce dont vous avez besoin est un processus qui accède à l'information stockée dans Cosmos (utilisation des API HDFS -Such comme WebHDFS ou HTTPFS-, interfectes de HIPFS, HTTPFS-Series, Offres générales Mapraduce sur En haut de Hadoop, etc.), puis implémentez le côté client de l'API NGSI selon lequel Orion implémente afin d'injecter des éléments de contexte dans Orion en fonction des informations que vous avez récupérées à partir de COSMOS. L'opération de clé à faire dans l'API Orion est updateContext .

Le diplôme d'automatisation dépendrait de la manière dont vous appliquez ce processus. Il peut être aussi automatisé que vous le souhaitez.

edit: Considérez cette réponse Commentaires, je vais essayer d'ajouter plus de détails.

Ce que je veux dire, c'est de développer un logiciel (appelons-le des logiciels APOS -A) Mise en œuvre du comportement suivant:

1. APOS saisira des données de COSMOS l'une des interfaces fournies par COSMOS, I.e. WebHDFS / httpfs, Hive, MapReduce Emplois, etc.
2. APOS traitera les données pour produire un certain résultat
3. APOS s'injectera qui aboutira à Orion, à l'aide de l'API de repos Orion décrite dans le manuel d'utilisation d'Orion . Il est particulièrement utile pour cette tâche le updateContext opération. À partir d'un point de vue client-serveur, Orion est un serveur exposant une API de repos et APOS est le client interagissant avec ce serveur.

Il est totalement à vous comment implémenter ces APOS et comment orchestrer le flux de 1 à 3 (par exemple, il peut fonctionner en mode batch toutes les minuit, être déclenché par interaction utilisateur sur un portail Web, etc.).

Aujourd'hui, FI-WARE ne fournit aucun matériau générique de convertir des données COSMOS en NGSI étant donné que chaque réalisation particulière des étapes 1 à 3 ci-dessus est différente et dépend du cas d'utilisation. Toutefois, notez qu'il existe un composant logiciel nommé cygnus qui implémente l'autre sens : de NGIS à Cosmos.