Machen Sie Orion-Abrufen von Daten von COSMOS und veröffentlichen

Question

Ich habe ein Abonnement zwischen Orion Contextbroker und Cosmos Bigdata mit CYGNUS eingerichtet, und Daten werden in Kosmos ordnungsgemäß angehalten, wenn ein Update auf Orion vorgenommen wird.

Ich möchte jedoch die Daten in Kosmos analysieren und die Ergebnisse an Orion zurücksenden und schließlich auf die Ergebnisdaten in Orion von "außerhalb" zugreifen.

Wie wäre man das?Natürlich möchte ich die Lösung, die ich als "automatisiert" wie möglich baue, aber meistens möchte ich dieses Problem einfach lösen.

Jeder Rat wird sehr geschätzt!

Answer 1

als allgemeine Reaktion (da auch die Frage sehr allgemein ist;), was Sie brauchen, ist ein Prozess, der Zugriff auf Informationen, die in Cosmos gespeichert sind (entweder mithilfe von HDFS-APIs-such als WebHDFS oder HTTPFS-, Hive-Anfragen, allgemeine MAPREDUCE-Jobs auf Spitze von Hadoop usw.), dann implementieren Sie die Clientseite der NGSI-API, dass Orion implementiert, um Kontextelemente in Orion auf der Grundlage der von Ihnen abgerufenen Informationen, die Sie von COSMOs abgerufen haben, injizieren. Die Schlüsselvorgänge in der Orion-API ist updatecontext .

Der Automatisierungsgrad würde davon abhängen, wie Sie diesen Prozess umsetzen. Es kann so automatisiert sein, wie Sie möchten.

edit: In Anbetracht dieser Antwortkommentare werde ich versuchen, mehr Details hinzuzufügen.

was ich meine, ist es, ein Stück Software zu entwickeln (nennen wir es apos -a-SOPPE-Software), um das folgende Verhalten zu implementieren:

.
1. APOS ergreift Daten von COSMOS von einem der von COSMOS bereitgestellten Schnittstellen, d. H. WebHDFS / HTTPFS, HIVE, MAPREDUCE-Jobs usw.
2. APOS verarbeitet die Daten, um ein anderes Ergebnis zu erzeugen
3. APOS Injizieren Sie das Ergebnis in Orion, mithilfe der in das Orion-Benutzerhandbuch . Es ist besonders nützlich für diese Aufgabe das updatecontext Betrieb. Aus einer Client-Server-Sicht ist der Orion ein Server, der eine REST-API aussetzt, und APOS ist der Client, der mit diesem Server interagiert.

Es liegt vollständig an Ihnen, wie Sie diesen APOS implementieren und den Fluss von 1 bis 3 oratrestrieren (z. B. kann im Batch-Modus alle Mitternachts im Batch-Modus ausgeführt werden, indem Sie von der Benutzerinteraktion auf einem Webportal usw. ausgelöst werden).

Im vorliegenden Moment liefert FI-WARE kein generisches Enabler, um von COSMOS-Daten in NGSI umzuwandeln, da jede bestimmte Realisierung der Schritte 1 bis 3 unterschiedlich ist und vom Anwendungsfall abhängt. Beachten Sie jedoch, dass es eine Softwarekomponente namens cygnus ist, die den anderen Weg implementiert : von ngis bis kosmos.