Spring Cloud Routage Dataflow par en-tête JSON

Question

J'ai essayé de créer un flux avec Spring Cloud Dataflow mais je n'ai pas eu beaucoup de chance (principalement en raison du manque de documentation).

Numéro 1: Accès à l'interface Web de dockerized Spring Nuage Dataflow Je dockerized un serveur cloud Spring fonctionne avec Kafka sur un conteneur Ubuntu base. Pour une raison quelconque, je ne peux pas accéder à l'interface graphique Web sous Windows (au < docker-machine ip>: 9393/dashboard). Cependant, j'ai un conteneur Docker Ubuntu distinct exécutant le proxy inverse Nginx, qui apparaît quand je vais à < docker-machine ip> /index.html ou etc. Je ne pense pas que ce soit un problème avec les ports, j'ai le printemps Configuration du conteneur de cloud avec -p 9393: 9393 et ​​le port est par ailleurs inutilisé.

Numéro 2: Acheminement par JSON-tête Mon but ultime est d'obtenir un fichier chargé dans de Nginx et routé basé sur son en-tête de JSON (il y a deux têtes de JSON différents), puis ingèrent des requêtes à Cassandra. Je peux faire tout cela sauf le tri par en-tête JSON. Quelle application recommanderiez-vous que j'utilise?

Answer 1

Numéro 1: Accès à l'interface Web de dockerized Spring Nuage Dataflow

Nous pourrions avoir besoin un peu plus de détails autour de ce sujet. En supposant que ce soit le serveur local, vous pourriez peut-être partager les scripts/image docker, afin que nous puissions l'essayer.

Numéro 2: Acheminement par JSON-tête

L'application router-sink serait à portée de main pour venir ce type de cas d'utilisation. Cette application achemine la charge vers des destinations nommées en fonction de certaines conditions, de sorte que vous avez la possibilité d'acheminer la charge utile avec ingest-query à Cassandra.

flux

1:

stream create test --definition "file | router --expression=header.contains('a')?':foo':':bar’" 

courant

2:

stream create baz --definition ":foo > cassandra --ingest-query=\"query1\"" 

courant 3:

stream create wiz --definition ":bar > cassandra --ingest-query=\"query2\"" 

(où: foo et bar sont nommés destinations)