JSONヘッダーによるSpring Cloud Dataflowルーティング

Question

Spring Cloud Dataflowを使用してストリームを作成しようとしましたが、多くの場合はドキュメントが不足しています。

問題1：dockerized春クラウドのデータフロー のアクセスウェブGUI私は基本的なUbuntuのコンテナ上で実行されているカフカdockerized春のクラウドサーバーを持っています。なんらかの理由で、私はWindowsのWeb GUI（< docker-machine ip>：9393/dashboard）にアクセスできません。しかし、私は< docker-machine ip> /index.htmlなどに行くときに表示されるNginxリバースプロキシを実行している別のDocker Ubuntuコンテナを持っています。私はそれがポートの問題ではないと思います。 -p 9393：9393でクラウドコンテナをセットアップし、それ以外の場合はポートを使用しません。

問題2：JSONヘッダーによってルーティング 私の究極の目標は、nginxのからにロードされたファイルを取得することであり、は（二つの異なるJSONヘッダーがあります）、そのJSONヘッダに基づいてルーティングされ、その後、カサンドラにクエリを摂取します。 JSONヘッダーによる並べ替えを除いて、これをすべて実行できます。どのアプリをお勧めしますか？

Answer 1

問題1：dockerized春クラウドのデータフローのアクセスウェブGUI

私たちは、この周りより少し詳細が必要な場合があります。これがローカルサーバであると仮定すると、ドッカースクリプト/イメージを共有できる可能性があるので、試してみることができます。

問題2：JSONヘッダー

router-sinkアプリケーションによってルーティングは、ユースケースのこのタイプの便利来ます。このアプリケーションは、特定の条件に基づいてペイロードを名前付きの宛先にルーティングします。したがって、ingest-queryのペイロードをCassandraにルーティングする機会があります。

ストリーム1：

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

ストリーム2：

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

ストリーム3：

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

（：fooとbarが命名されている宛先）