Rendere Orion recupera i dati da Cosmos e pubblica

Question

Ho impostato un abbonamento tra contesto ORIONBROKER e Cosmos BigData utilizzando il cygnus e i dati vengono correttamente persistiti in cosmo quando viene effettuato un aggiornamento su Orion.

Ma voglio analizzare i dati in cosmo e restituire i risultati a Orion e infine accedere ai dati dei risultati in Orione da "Atmosfera".

Come lo farebbe questo?Certo, vorrei che la soluzione che costruisco sia come il più possibile "automatizzata", ma soprattutto voglio solo risolvere questo problema.

Qualsiasi consiglio è molto apprezzato!

Answer 1

come risposta generale (come anche la domanda è molto generale;), ciò di cui hai bisogno è un processo che acceda alle informazioni memorizzate in Cosmos (utilizzando HDFS API -SUCCH come WebHDFS o HTTPFS-, Hive Query, i lavori generali di MapReduce su cima di Hadoop, ecc.), Quindi implementare il lato client dell'API NGSI che ORION attre per iniettare elementi di contesto in Orione sulla base delle informazioni che hai recuperato da Cosmos. L'operazione chiave per farlo nell'API ORION è updatecontext .

Il grado di automazione dipenderà da come implementa il processo. Può essere automatizzato come vuoi.

Modifica: Considerando questo commento di risposta, proverò ad aggiungere più dettagli.

Cosa intendo è sviluppare un software (chiamiamolo APOS -A pezzo di software) implementazione del seguente comportamento:

.
1. APOS afferrerà i dati da Cosmos qualsiasi delle interfacce fornite da Cosmos, I.e. WebHDFS / HTTPFS, HIVE, MAPREDUCE Jobs, ecc.
2. APOS elaborerà i dati per produrre qualche risultato
3. APOS inietterà che il risultato di Orion, utilizzando l'API di Rest Orion descritto in Il manuale dell'utente orion . È particolarmente utile per quel compito il UpdateContext operazione. Da un punto di vista del server client, ORION è un server che espone un API di riposo e APOS è il client che interagisce con quel server.

È completamente attivo come implementare questo APOS e come orchestrare il flusso da 1 a 3 (ad esempio, può essere eseguito in modalità batch tutte le mezzanotte, essere attivato dall'interazione dell'utente su un portale web, ecc.).

Al momento attuale, il fi-ware non fornisce alcuna enabler generico di convertire dai dati dell'universo su NGSI, dato che ogni particolare realizzazione dei passaggi da 1 a 3 sopra è diversa e dipende dal caso d'uso. Tuttavia, nota che c'è componente software denominato Cygnus che implementa l'altro modo : da ngis al cosmo.